[CDC:ErrKafkaNewSaramaProducer]new sarama producer: kafka: client has run out of available brokers to talk to (Is your cluster reachable?)

【 TiDB 使用环境】生产\测试环境\ POC
【 TiDB 版本】5.4.1
【遇到的问题】
TICDC 对接下游kafka,下游kafka 是oem版本(2.3.0-oem-7.0.1)而非开源版本,主要出现以下2个问题:
1)如果kava 版本配置成oem 对应的开源版本(如2.3.0),则报错“[CDC:ErrKafkaNewSaramaProducer]new sarama producer: kafka: client has run out of available brokers to talk to (Is your cluster reachable?)”
2)如果kafka 版本配置成下游oem版本完全保持一样(如2.3.0-oem-7.0.1),则报错“[CDC:ErrKafkaInvalidVersion]invalid kafka version: invalid version 2.3.0-oem-7.0.1
【复现路径】做过哪些操作出现的问题
【问题现象及影响】
【附件】

  • 相关日志、配置文件、Grafana 监控(https://metricstool.pingcap.com/)
  • TiUP Cluster Display 信息
  • TiUP CLuster Edit config 信息
  • TiDB-Overview 监控
  • 对应模块的 Grafana 监控(如有 BR、TiDB-binlog、TiCDC 等)
  • 对应模块日志(包含问题前后 1 小时日志)

若提问为性能优化、故障排查类问题,请下载脚本运行。终端输出的打印结果,请务必全选并复制粘贴上传。

invalid-version可能是版本不兼容

[CDC:ErrKafkaNewSaramaProducer]new sarama producer: kafka: client has run out of available brokers to talk to (Is your cluster reachable?)”
2)如果kafka 版本配置成下游oem版本完全保持一样(如2.3.0-oem-7.0.1这个问题主要有下面几方面原因

1.kafka-version没有指定
2.kafka开启sasl验证,cdc没有支持
https://github.com/pingcap/tiflow/issues/1106
3.cdc版本兼容不了当前的kafka
4. server.properties中的listerers要配置,不要用localhost listeners=PLAINTEXT://kafka_ip:9092
5.cdc机器不能访问kafka的9092端口
6.cdc-ctl的机器不能访问kafka的9092端口

我遇到的问题是因为我kafka的9092端口只对cdc机器开放了,没有对cdc-ctl机器开放

该主题在最后一个回复创建后60天后自动关闭。不再允许新的回复。