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

sink_url能配置多个kafka的broker地址吗,只配置一个的话。那台机器挂了怎么办?

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

-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 个赞

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