文档不清晰或不完整,请按照下方模板提交
-
问题分类:没有高可用想描述
-
出现的页面:链接+截图
-
出现的问题:
建议增加高可用uri地址
- –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"