Tidb cdc 写入kafka 配置压缩

【 TiDB 使用环境】生产环境
【 TiDB 版本】 5.4.1

【遇到的问题:问题现象及影响】

tidb cdc 写kafka 没有配置压缩,导致kafka 流量上线,数据消费异常;

【资源配置】
【附件:截图/日志/监控】

查看文档资料,未找到相关配置,想来想去还是直接加测试一下吧,增加配置(不知道那个,就两个都加上 )如下:
&kafka.compression.type=snappy&compression.type=snappy

不知道会不会有效

观察了一天,没有起效

看官方文档,kafka的sink url 没有提供compression.type这个参数,应该是硬编码在ticdc中,可以提issue



谢谢,抱拳了

此话题已在最后回复的 60 天后被自动关闭。不再允许新回复。