Kafka连接失败提示Broker may not be available错误排查咨询

核心问题定位 #

从错误日志可直接判断是Spring Boot的生产者、消费者客户端均无法连接配置的localhost:9092 Kafka服务端，同时你的配置文件、业务代码存在两处明显错误。

分步排查修复 #

• 第一步：确认Kafka服务状态与端口连通性
  本地原生部署的Kafka，执行jps命令查看进程，存在Kafka和QuorumPeerMain（ZooKeeper进程）说明基础服务启动正常；Docker部署的Kafka执行docker ps确认容器运行正常，且9092端口已映射到宿主机。
  执行telnet localhost 9092验证端口连通性，无法连通说明Kafka未正常启动、端口不是9092，或是防火墙拦截了端口访问。
• 第二步：修正Kafka配置文件错误
  你当前生产者配置错误使用了反序列化类，生产者需配置序列化类，修正后的完整配置如下：

spring.kafka.consumer.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=mygroup
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

spring.kafka.producer.bootstrap-servers=localhost:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

• 第三步：校验Kafka服务端监听配置
  打开Kafka安装目录下config/server.properties文件，检查如下配置：
  • listeners需配置为PLAINTEXT://localhost:9092，若需要允许外部机器访问可改为PLAINTEXT://0.0.0.0:9092
  • Docker部署的Kafka需额外校验KAFKA_ADVERTISED_LISTENERS环境变量，本地使用需配置为PLAINTEXT://localhost:9092
• 第四步：修正业务代码遗漏注解
  KafKaProducerService类未添加@Service注解，会导致Spring无法扫描到该类，KafkaTemplate注入失败，代码调整如下：

@Service // 补充该注解
public class KafKaProducerService {
    private static final Logger logger = 
            LoggerFactory.getLogger(KafKaProducerService.class);
     
    public static final String topic = "mytopic";
      
    @Autowired 
    private KafkaTemplate<String, String> kafkaTemp;
      
    public void publishToTopic(String message) {
        System.out.println("Publishing to topic "+topic);
        this.kafkaTemp.send(topic, message);
    }
}

• 第五步：确认Topic存在
  若你关闭了Kafka自动创建Topic的配置，需手动创建mytopic，执行命令如下：
  Linux/Mac：kafka-topics.sh --create --topic mytopic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
  Windows：kafka-topics.bat --create --topic mytopic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1

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