建议cdc同步到kafka文档中增加高可用的uri配置

文档不清晰或不完整,请按照下方模板提交

  1. –sink-uri=“kafka://127.0.0.1:9092,127.0.0.2:9092,127.0.0.3:9092/kafka-topic-name?protocol=canal-json&partition-num=3&replication-factor=1&max-message-bytes=1048576” --config=“changefeed.conf”

Sink URI 用于指定 TiCDC 目标系统的连接信息,遵循以下格式:

[scheme]://[userinfo@][host]:[port],[userinfo@][host]:[port],[userinfo@][host]:[port][/path]?[query_parameters]

example

--sink-uri="kafka://127.0.0.1:9092,127.0.0.2:9092,127.0.0.3:9092/kafka-topic-name?protocol=canal-json&partition-num=3&replication-factor=1&max-message-bytes=1048576" --config="changefeed.conf"
1 个赞

宝,你真棒

虽然他没写,但是大家默认就是写多个kafka地址的吧

已提pr啦:TiCDC: modify Kafka sink uri format by wk989898 · Pull Request #17675 · pingcap/docs · GitHub

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