ticdc中sink-uri=kafka中ip地址能不能写多个?

有多个kafka,ticdc支不支持写多个kafka ip地址

如果支持,要怎么写?

可以写多个broker地址,跟其他应用访问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 个赞

:call_me_hand:

1 个赞

可以的

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