SpringBoot kafka Connection to node -1(localhost 127.0.0.1:9092) could not be established. Broker ma_spring boot connection to node 1001 (localhost/127

@[TOC](SpringBoot kafka Connection to node -1(localhost 127.0.0.1:9092) could not be established. Broker may not be available)

前言

SpringBoot整合kafka，启动时无法连接kafka服务器。Warn信息：
Connection to node -1(localhost 127.0.0.1:9092) could not be established. Broker may not be available

排查过程：

1. 防火墙，检查9092端口是否已经开放
2. kafka配置文件：
   config/server.properties文件，检查以下两个配置：

# 允许外部端口连接，默认只允许本机连接                                           
listeners=PLAINTEXT://0.0.0.0:9092  
# 外部代理地址                                                
advertised.listeners=PLAINTEXT://192.168.1.11:9092

1
2
3
4
5

3. 检查springboot的配置文件：
   除了要配置:
   spring.kafka.consumer.bootstrap-servers
   spring.kafka.producer.bootstrap-servers
   注意还需要配置：
   spring.kafka.bootstrap-servers

   这个配置是kafka.clients.admin.AdminClientConfig的服务器配置，用于检查创建topic、partition、replication

# 
1

我的错误解决

我在自己搭建练习项目时，就是2、3点没配置好，导致连接超时