用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}?

小蕊 发表于: 2016-10-08   最后更新时间: 2016-10-08  
  •   25 订阅,11850 游览

使用发送命令

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

然后随便打入一条消息,就一直刷警告 WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION},请问有人遇到过吗?

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
nihao
[2016-10-08 17:58:54,821] WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2016-10-08 17:58:55,026] WARN Error while fetching metadata with correlation id 1 : {test=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2016-10-08 17:58:55,128] WARN Error while fetching metadata with correlation id 2 : {test=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2016-10-08 17:58:55,230] WARN Error while fetching metadata with correlation id 3 : {test=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
[2016-10-08 17:58:55,332] WARN Error while fetching metadata with correlation id 4 : {test=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)





征集:如果你也是一个热爱分享文章的人,愿意参与贡献文章来补充完善本网的内容,欢迎入群:14085484

发表于: 1年前   最后更新时间: 1年前   游览量:11850
上一条: kafka启动报 java.lang.ExceptionInInitializerError at kafka.network.RequestChannel$Request. 有遇到的吗?
下一条: mac系统升级后,git报xcrun: error: invalid active developer path (/Library/Developer/CommandLineTools), missing xcrun at: /Librar

评论…


  • 你看下kafka集群的配置文件,是否设置了auto.create.topics.enable=false。如果有,就设置为ture。
    可能是你的topic不存在,导致的。让它自动创建。
    或者你也可以手动创建
    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 4 --topic test
    • 我的也是没有leader,这种情况是怎么解决的??
      ./bin/kafka-topics.sh --zookeeper zk1.node:12181,zk2.node:12181,zk3.node:12181  --describe --topic test05
      Topic:test05 PartitionCount:3 ReplicationFactor:3 Configs:
      Topic: test05 Partition: 0 Leader: none Replicas: 2,1,0 Isr:
      Topic: test05 Partition: 1 Leader: none Replicas: 0,2,1 Isr:
      Topic: test05 Partition: 2 Leader: none Replicas: 1,0,2 Isr:
        • 问题解决了:

          无法与kafka集群建立连接,无法获取meta信息导致的;通常需要修改kafka中的server.properties文件,调整“listeners”、“host.name”配置项;其中“listeners”中明确指定绑定到本机的内网IP,"host.name"保持默认或者不声明

          解决:增加一行配置host.name=zk1.node解决
          • 评论…
            • in this conversation
              提问