ticdc的下游为kafka时,怎么做负载均衡呢

可以配置多个啊,用, 隔开就行了

-sink-uri=“kafka://127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094/topic-name?protocol=canal-json&kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1”

参考这个帖子

2 个赞