kafka调试中遇到Connection to node -1 could not be established. Broker may not be available.

当我们在使用Kafka时，有时会遇到“Connection to node -1 could not be established. Broker may not be available.”这个错误，这在Kafka调试中是比较常见的问题。这个问题的产生可能与以下原因有关：

• Kafka与Zookeeper连接故障
• Kafka Broker宕机
• Kafka配置错误

以下是我们处理此问题的攻略：

1. 检查Kafka与Zookeeper的连接

首先，我们需要确保Kafka与Zookeeper之间的连接正常运行。可以通过执行以下命令来检查连接是否成功：

./kafka-topics.sh --zookeeper localhost:2181 --list

如果你能看到你的主题列表，则表示Kafka与Zookeeper服务器的连接已经建立。

2. 确认Broker是否可用

如果Kafka和Zookeeper之间的连接已经建立，则可以继续检查Kafka Broker是否可用。可以通过以下命令来查看Broker的状态：

./kafka-topics.sh --zookeeper localhost:2181 --describe --topic my_topic

例如，如果我们想查看名称为my_topic的主题，我们可以使用以下命令：

./kafka-topics.sh --zookeeper localhost:2181 --describe --topic my_topic

如果你发现Kafka Broker宕机或主题配置错误的话，那么你就需要查看配置文件并进行适当修改。

示例1：检查Kafka Broker和Zookeeper的端口

如果你发现Kafka Broker宕机了，则建议检查Kafka Broker和Zookeeper的端口。我们可以通过查看Kafka Broker的配置文件来知道它是否绑定到正确的端口。配置文件通常位于Kafka的安装目录下config/server.properties。 首先，我们应该检查listeners和advertised.listeners属性，以确保它们正确设置。例如，如果我们使用的是默认端口9092，则配置文件的内容应该如下：

listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://<broker-host>:9092

另外，我们还需要确保Zookeeper的端口与Kafka Broker的配置文件中的端口相匹配。在通用情况下，Zookeeper的配置应该位于$KAFKA_HOME/config/zookeeper.properties中，并且默认监听端口是2181。

示例2：配置文件设置错误

如果你发现Kafka Broker和Zookeeper都能正常使用，但是Kafka客户端仍然无法连接，则可能是由于Kafka客户端配置文件中的错误设置导致的。

例如，如果你的Kafka Broker配置中使用了非默认端口，则你的Kafka客户端也应该使用相同的端口进行连接。我们可以在Kafka客户端的配置文件中指定bootstrap.servers属性来指定Kafka Broker的连接地址和端口：

bootstrap.servers=localhost:9092

在检查完Kafka Broker和Zookeeper之间的连接，并排除配置文件设置错误的情况下，你通常就可以成功解决“Connection to node -1 could not be established. Broker may not be available.”的问题了。