Spring-Kafka应用连接失败求助：无法连接本地Broker

1. 确认Kafka Broker是否正常运行 #

• 本地环境下，直接检查Kafka进程状态：
  • Linux/macOS：执行 ps aux | grep kafka
  • Windows：打开任务管理器，查找Kafka相关进程
• 若Broker未启动，使用KRaft模式启动（无需ZooKeeper）：执行 bin/kafka-server-start.sh config/kraft/server.properties（Linux/macOS）或对应Windows脚本

2. 检查Kafka Broker的监听配置 #

• 打开Kraft模式配置文件config/kraft/server.properties，核对以下参数：
  • listeners：确保包含客户端可访问的地址，比如 listeners=PLAINTEXT://0.0.0.0:9092（允许所有IP访问）
  • advertised.listeners：需与Spring应用配置的地址一致，比如 advertised.listeners=PLAINTEXT://localhost:9092
• 修改配置后重启Kafka Broker

3. 核对Spring应用的Kafka配置 #

• 检查application.properties中的spring.kafka.bootstrap-servers参数，确保值为localhost:9092（或Broker实际的IP+端口），避免端口或主机名写错
• 若Broker运行在容器/远程机器，将localhost替换为对应IP或主机名，同时确保端口对外开放

4. 排查网络连通性 #

• 在应用所在机器执行 telnet localhost 9092 或 nc -zv localhost 9092，测试Broker端口是否可达
• 若不通，检查本地防火墙是否放行9092端口，云服务器则需确认安全组规则

5. 验证版本兼容性 #

• 确认pom.xml中Spring-Kafka与Kafka Broker的版本匹配：
  • 例如Spring-Kafka 3.1.x对应Kafka 3.5.x，版本不匹配可能导致连接失败
• 可在pom.xml中明确指定客户端版本：

  <dependency>
      <groupId>org.springframework.kafka</groupId>
      <artifactId>spring-kafka</artifactId>
      <version>3.1.2</version>
  </dependency>
  <dependency>
      <groupId>org.apache.kafka</groupId>
      <artifactId>kafka-clients</artifactId>
      <version>3.5.1</version>
  </dependency>
  

6. 查看Broker日志定位问题 #

• 打开Kafka日志目录下的server.log，检查是否有启动失败、端口占用等异常信息（比如端口被其他程序占用会导致Broker无法监听）

内容的提问来源于stack exchange，提问作者emresahin