背景:ticdc往kafka同步增量数据,设置了partition-num=4
现象:现在下游kafka的分区只有一个有数据,其余分区都是空的。
版本:6.1.7
这是啥原因呢?是因为没有设置"dispatchers"吗,我没有单独对这个参数进行配置,然后看cdc任务详情里面这个dispatchers是null,看网上的文档说如果需要均衡打到各个分区需要配置这个参数。
cdc sink的配置
到kafka上看看这个topic具体的分区