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

kafka报错内容：

WARN [Consumer clientId=consumer-1, groupId=console-consumer-950] Connection to node -1 could not be established. Broker may not be available.

这是因为你的配置文件中的PLAINTEXT跟你请求的内容不同。举例来说，我在配置文件里配置的listeners=PLAINTEXT://10.127.96.151:9092，但是我想测试的时候请求的是./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic1 --from-beginning

正确的应该是./kafka-console-consumer.sh --bootstrap-server 10.127.96.151:9092 --topic topic1 --from-beginning

您可能感兴趣的文章:

• python3实现从kafka获取数据,并解析为json格式,写入到mysql中
• 浅谈Java消息队列总结篇（ActiveMQ、RabbitMQ、ZeroMQ、Kafka）
• 通过pykafka接收Kafka消息队列的方法
• kafka生产者和消费者的javaAPI的示例代码
• Java使用kafka发送和生产消息的示例
• Kafka利用Java实现数据的生产和消费实例教程
• Kafka使用Java客户端进行访问的示例代码
• Java API方式调用Kafka各种协议的方法
• Spring纯Java配置集成kafka代码实例