You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.10.08 08:45:01