tidb-v5.3.1：ticdc创建同步任务到kafka报controller is not available

🪐 TiDB 技术问题 部署&运维管理
1

【 TiDB 使用环境】生产\测试环境\ POC

image
image1473×279 30.4 KB

【 TiDB 版本】
tidb v5.3.1
【遇到的问题】
在使用如下指令创建同步任务时，报 Error: [CDC:ErrKafkaNewSaramaProducer]kafka: controller is not available: kafka: controller is not available 错误：

tiup cdc cli changefeed create --pd=http://172.16.30.145:2379 --changefeed-id="simple-replication-task" --sort-engine="unified" --sink-uri="kafka://172.16.30.101:9092/jc-search-test?protocol=canal-json&kafka-version=2.7.0&partition-num=6&max-message-bytes=67108864&replication-factor=1"

具体报错信息如下：

image
image1651×584 90.2 KB

【复现路径】做过哪些操作出现的问题
【问题现象及影响】
其中kafka的ip和端口都是能正常访问连通的，服务器也能正常连接kafka。但在创建同步任务会出现上述报错。

2

截图上报警挂了 业务不正常

3

试了下重启altermanger，报

level=info ts=2022-09-15T12:21:07.400328946Z caller=main.go:140 msg="Starting Alertmanager" version="(version=0.17.0, branch=HEAD, revision=c7551cd75c414dc81df027f691e2eb21d4fd85b2)"
level=info ts=2022-09-15T12:21:07.400408611Z caller=main.go:141 build_context="(go=go1.12.4, user=root@932a86a52b76, date=20190503-09:10:07)"
level=error ts=2022-09-15T12:21:07.400708319Z caller=main.go:165 msg="unable to initialize gossip mesh" err="create memberlist: Could not set up network transport: failed to obtain an address: Failed to start TCP listener on \"172.16.30.145\" port 9094: listen tcp 172.16.30.145:9094: bind: cannot assign requested address"

服务器防火墙关闭了，请问是哪里出问题了嘛（9093，9094端口也没有占用信息）

4

kafka 的版本参数，分区参数，副本参数和线上一致么？

5

你这个和kafka 的没关系 ，你看下从cdc 对应的节点上能正常连接kafka 进行消息生产和消费么