TICDC连接kafka写法问题

🪐 TiDB 技术问题
1

TICDC连接kafka，在没有鉴权的情况下,使用
tiup cdc cli changefeed create --pd=http://IP:2379 --sink-uri=“kafka://IP:9092/0511kafka?kafka-version=3.9.0” --changefeed-id=“0511cdc” --config tidb_ob_uat.toml
可以创建成功，新的kafka强制鉴权，使用
tiup cdc cli changefeed create --pd=http://IP:2379 --sink-uri=“kafka://IP:9092/tidb?kafka-version=3.5.1&sasl-mechanism=SCRAM-SHA-512&protocol=SASL_PLAINTEXT&sasl-user=kafka&sasl-password=xxxxx” --changefeed-id=“0511cdc” --config tidb_ob_uat_2.toml
就会报错

image
image1072×189 5.59 KB

请问如何正确填写才能通过:
[kafka鉴权信息]
security.protocol=SASL_PLAINTEXT
sasl.mechanism=SCRAM-SHA-512
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username=“kafka” password=“xxx”;

3

kafka发送消息
sh kafka-console-producer.sh --bootstrap-server IP:9092 --topic test2 --producer.config ./kafka-test.properties
kafka消费消息命令
sh kafka-console-consumer.sh --bootstrap-server IP:9092 --topic test2 --group test-group --from-beginning --consumer.config ./kafka-test.properties
kafka查询topic详情
sh kafka-topics.sh --bootstrap-server IP:9092 --describe --topic test2 --command-config ./kafka-test.properties
kafka查询topic列表
sh kafka-topics.sh --bootstrap-server IP:9092 --list --command-config ./kafka-test.properties

日常连接是可以通过文件进行鉴权的，请问TICDC是否也支持这种文件的形式进行鉴权呢？

4

4.0版本也太老了，这个版本的ticdc问题很大

5

有没有相关案例 也可以参考一下？

6

密码有特殊字符吗？4.0的版本ticdc好像对特殊字符不支持，后续新版本可以把含有特殊字符的密码转化成URL encode

7

https://docs-archive.pingcap.com/zh/tidb/v4.0/manage-ticdc/#sink-uri-配置-kafka

v4.0 ticdc2kafka没有sasl相关参数。

8

确切得说是v4.0.14及以后版本才支持sasl。
https://github.com/pingcap/tiflow/pull/1789

9

看来没戏了 只能搞个无鉴权的kafka操作了 谢谢

10

版本太低了 升级吧。