卡夫卡控制台消费者。错误无法建立与节点0的连接。可能无法使用布鲁克

问题描述 投票:0回答:1

我正试图在我的本地(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-producer --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
java apache-kafka kafka-consumer-api
1个回答
0
投票
  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
  1. 在server.properties中添加/修改下面的属性,如下所示: zookeeper.connect=<computer name>:2181 在zookeeper.properties中: 在D:/ drive中创建一个文件夹,并将其放在zookeeper.properties中,如下所示 DATADIR = d:\\ FOLDERNAME \\动物园管理员
  2. 您也可以在所有命令中使用localhost而不是127.0.0.1。

尝试这些,它可能会有所帮助

© www.soinside.com 2019 - 2024. All rights reserved.