CDC的kafka地址怎么填写多个

troy_wang · 2020 年10 月 29 日 05:01

大佬们好，请问CDC的kafka地址怎么填写多个？–sink-uri=“kafka://127.0.0.1:9092/cdc-test?kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1”

来了老弟 · 2020 年10 月 29 日 05:44

你好,
逗号分隔即可.

troy_wang · 2020 年10 月 29 日 06:15

kafka://127.0.0.1:9092,127.0.0.1:9092,127.0.0.1:9092/cdc-test?kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1
还是
–sink-uri=“kafka://127.0.0.1:9092/cdc-test?kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1,kafka://127.0.0.1:9092/cdc-test?kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1,kafka://127.0.0.1:9092/cdc-test?kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1"

来了老弟 · 2020 年10 月 29 日 06:18

大佬, 辛苦试下如何.

zhenjiaogao · 2020 年10 月 29 日 06:25

这样试下看看：

kafka://127.0.0.1:9092,127.0.0.1:9092,127.0.0.1:9092/cdc-test?kafka-version=2.4.0&partition-num=6&max-message-bytes=67108864&replication-factor=1

troy_wang · 2020 年10 月 29 日 09:37

大佬补充一下文档好吗

zhenjiaogao · 2020 年10 月 29 日 10:30

嗯啊，在文档中有明确的示例会更友好，感谢建议 ~~

system · 2022 年10 月 31 日 19:08

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