Kafka Connect Standalone启动报无法连接描述Kafka集群错误如何解决
Kafka Connect Standalone 启动报错排查解决
该报错核心原因是Kafka Connect无法正常连接到Kafka Broker集群,按以下步骤逐一排查修复:
1. 修复核心配置冲突
你当前connect-standalone.properties中的listeners参数配置错误:该参数为Kafka Connect服务自身的监听地址,不能与Kafka Broker已占用的9092端口冲突,修改配置如下:
# 注释原冲突配置,使用Kafka Connect默认的8083端口 listeners=PLAINTEXT://localhost:8083
2. 验证Kafka Broker可用性
启动Connect前先确认Broker服务正常可连接:
- 检查9092端口监听状态:
netstat -tunlp | grep 9092 - 用Kafka官方脚本测试连接:
kafka/bin/kafka-topics.sh --list --bootstrap-server localhost:9092
上述命令正常返回Topic列表则说明Broker服务无异常。
3. 验证插件路径合法性
执行命令确认Cassandra sink插件路径配置正确、文件存在且有权限访问:
ls -l /home/shamama/kafka-connect-cassandra-sink-1.4.0/kafka-connect-cassandra-sink-1.4.0.jar
4. 重启服务
修改配置后重新执行启动命令:
kafka/bin/connect-standalone.sh kafka/config/connect-standalone.properties kafka-connect-cassandra-sink-1.4.0/conf/cassandra-sink-standalone.properties
内容的提问来源于stack exchange,提问作者haq
相关产品推荐
相关产品推荐

