未解决 canal.mq.partitionsNum配置不生效

[navyaijm2017]

canal的版本：1.1.4
kafka版本：2.6.0
场景：mysql—》kakfa

配置了kafka的topkic是3个分区，但是canal自动创建的topic缺是只有一个分区

[junyu-cloudcanal]

@navyaijm2017 也就是你手动创建了其他分区就正常了么？

[navyaijm2017]

@junyu-cloudcanal 我发送了50万条数据，因为是一个分区，同步都卡主了，然后我手动改成多个分区，同步恢复正常

[junyu-cloudcanal]

你发送了多少条数据？因为不会显式创建topic，而是实时根据数据指定的 partition 自动创建。