计划是要升级的

内存是256G，每个节点设置56G

明白了，多谢解惑

这个试过了 也不行

但v4.0.14就没有这个问题，我想问的是这两个版本之间的差异

版本写错了，是 v5.0.4，暂时升级不了版本

通过直连pd，将数据写入 tikv，当然是备份tikv了。场景连接：TiKV 最佳实践 | JuiceFS Document Center

原来我的kafka账号只有WRITE和READ权限，后来加了 对 Topic 资源类型的 Create 、Describe（这） 权限。 对 Cluster 资源类型的 DescribeConfigs 权限。 官网写了 [image] 我们没有注意到这里 现在问题解决了 多谢支持

好 我们测试环境测试一下6.5.2

无认证是可以的

我们下游kafka版本是2.7.1是支持的呀，为什么认证还是有问题

[image] [image] kafka可以正常读写。目标端kafka版本为2.7.1 今天我用高版本kafka3.1.2 client端 .kafka-console-producer.sh测试会报Cluster authorization failed. 用kafka2.7.1 client端.kafka-console-producer.sh测试可以正常读写。 请问ticdc的kafka client端是不是也有版本区分，ticdc是v6.1.3，此版本是否支持kafka2.7.1

6.1.3版本支持这些参数吗 [sink.kafka-config] sasl-mechanism = “SCRAM-SHA-256” sasl-user = “user” sasl-password = “password” 报错: component TiCDC changefeed’s config file /home/tidb/changefeed-news-v8.toml contained unknown configuration options: sink.kafka-config, sink.kafka-config.sasl-mechanism, sink.k…

DEBUG没有有用的信息 [kafka-client]这个配置是在哪,cdc.conf吗

可以的 我专门找人用测试了一下可读可写

不是明文，提供方给的是这个: security.protocol=SASL_PLAINTEXT sasl.mechanism=SCRAM-SHA-256

请问如何把kafka以下配置加到ticdc命令行中配置 properties.put(“security.protocol”,“SASL_PLAINTEXT”); properties.put(“sasl.mechanism”,“SCRAM-SHA-256”); properties.put(“sasl.jaas.config”,“org.apache.kafka.common.security.scram.ScramLoginModule required username=‘账户’ password=‘密码’;”);

tiup ctl:v6.1.3 cdc changefeed create --pd=http://10.20.10.10:2379 --sink-uri=“kafka://kafka1.com:9092,kafka2.com:9092,kafka3.com:9092/topic1?kafka-version=2.7.0&sasl-user=user&sasl-password=password&sasl-mechanism=SCRAM-SHA-256&partition-num=5&max-message-bytes=1048576&replication-factor=1&protocol…

是一个第三方的程序，具体做了什么操作我们需要再查一下