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 分钟后被自动关闭。不再允许新回复。