java - 卡夫卡控制台消费者。错误 无法建立与节点 0 的连接。代理可能不可用

Question

我正在尝试在本地(Windows 7 虚拟桌面)中使用来自 kafka 的消息

1. zookeeper 和 kafka 在同一台本地计算机上运行
2. 创建主题

kafka-topics --zookeeper 127.0.0.1:2181 --topic first_topic --create -- partitions 3 --replication-factor 1
Created successful 

1. 生成消息kafka-console-生产者 --broker-list 127.0.0.1:9092 --topic first_topic没有错误，我只是按 Ctrl+C 结束生成
2. 消费消息

kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic first_topic --from-beginning
ERROR : 
WARN [Consumer clientId=consumer-1, groupId=console-consumer-71129] Connection to node 0 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

请帮忙!

在 server.properties 设置中

broker.id=0
advertised.port=9092
advertised.host.name=127.0.0.1
listeners=PLAINTEXT://127.0.0.1:9092
advertised.listeners=PLAINTEXT://127.0.0.1:9092

Answer 1

1. 如果您在本地计算机上运行，​​则无需添加以下属性。

注释掉这些。

advertised.port=9092
advertised.host.name=127.0.0.1
listeners=PLAINTEXT://127.0.0.1:9092
advertised.listeners=PLAINTEXT://127.0.0.1:9092

在 server.properties 中添加/修改以下属性，如下所示:

zookeeper.connect=<computer name>:2181

在zookeeper.properties中:

在D:/驱动器中创建一个文件夹并将其放入zookeeper.properties中，如下所示

dataDir=D:\\文件夹名称\\zookeeper

您也可以在所有命令中使用 localhost 代替 127.0.0.1。

试试这些，可能会有帮助