当前位置: 首页 > 知识库问答 >
问题:

Kafka-控制台-消费者。错误,无法建立到节点0的连接。Broker可能不可用

燕寒
2023-03-14

我正试图在我的本地(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. produce message kafka-console-producer--broker-list 127.0.0.1:9092--topic first_topic没有错误,我只是做Ctrl+C do end producing
  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)
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

共有1个答案

宇文峰
2023-03-14
  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中添加/修改以下属性。属性如下所示:

zookeeper.connect=<computer name>:2181
 类似资料:
  • 我试图用Spring Boot 2.1.7启动Spring-Kafka。用Java12在localhost上发布。

  • 我在Zookeeper和Kafka(各1个实例)中运行我的locahost。 我成功地从Kafka创建了一个主题: Kafka日志显示: 但Zookeeper的日志显示: 如果我尝试生成消息: server.properties(在Kafka中)是: 看来动物园管理员没有注册任何经纪人。 有什么建议吗?

  • 获取错误:“org.apache.kafka.clients.NetworkClient:[Consumer ClientID=Consumer-1,GroupID=Inter]无法建立到节点-1的连接。代理可能不可用。” 我尝试将Java版本切换到11和8以及各种属性 2019-08-22 16:25:20.580警告5865---[restartedMain]org.apache.kafka.

  • 我正在为Kafka0.9.0.0做Kafka快速入门。 我让zookeeper在监听,因为我运行了 只有一个代理在处侦听,因为我运行了 我有一个制作人在主题“测试”上发帖,因为我跑了 当我运行旧的API使用者时,它通过运行 但是,当我运行新的API使用者时,我在运行时没有得到任何东西 是否可以使用新的API从控制台使用者订阅主题?我该怎么修好它?

  • 现在我正面临着连接生产者/消费者的问题。 > 我使用以下命令创建了一个客户端密钥存储库, 将CA证书添加到密钥库, 警告与节点-1的连接在身份验证期间终止。这可能表明身份验证由于凭据无效而失败。(org.apache.kafka.clients.NetworkClient) 怀疑我在客户端配置中缺少了什么。如有任何帮助,将不胜感激。

  • [kafka-producer-network-thread>producer-1]警告org.apache.kafka.clients.networkclient-[Producer clientid=producer-1]无法建立到节点0的连接(/xx.xx.xx.xx.xx:9092)。代理可能不可用。 [主]信息org.apache.Kafka.clients.Producer.kafka