我正试图在我的本地(Windows 7虚拟桌面)消费来自kafka的消息
kafka-topics --zookeeper 127.0.0.1:2181 --topic first_topic --create -- partitions 3 --replication-factor 1
Created successful
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
评论这些。
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
zookeeper.connect=<computer name>:2181
在zookeeper.properties中:
在D:/ drive中创建一个文件夹,并将其放在zookeeper.properties中,如下所示
DATADIR = d:\\ FOLDERNAME \\动物园管理员尝试这些,它可能会有所帮助