无法写入Kafka主题

pdtvr36n  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(302)

我在google云上有hortonworks数据平台。ambari说Kafka和zookeeper都在运行,但我不能给Kafka的主题写任何数据。例如,

[mpcs53013@hadoop-m ~]$ /usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --broker-list 10.240.0.5:6667 --topic mpstest2
a
[2015-11-18 04:15:05,800] WARN Error while fetching metadata [{TopicMetadata for topic mpstest2 -> 
No partition metadata for topic mpstest2 due to kafka.common.LeaderNotAvailableException}] for topic [mpstest2]: class kafka.common.LeaderNotAvailableException  (kafka.producer.BrokerPartitionInfo)

我创建的每个主题都会出现这种情况。
缺少一个领导说明Zookeeper不配合,但不知道如何诊断。如果我让Kafka描述这个主题,它也会说没有领袖。
[编辑]经过大量实验后,/kafka/brokers/0似乎缺少zookeeper中的“endpoints”部分。

get /brokers/ids/0
{"jmx_port":-1,"timestamp":"1447878898217","host":"hadoop-m.c.mpcs53013-2015.internal","version":1,"port":6667}
...

如果我手动编辑zookeeper数据

set /brokers/ids/0 {"jmx_port":-1,"timestamp":"1447878898217","endpoints":["PLAINTEXT://hadoop-m.c.mpcs53013-2015.internal:6667"],"host":"hadoop-m.c.mpcs53013-2015.internal","version":1,"port":6667}

然后一切正常!
所以我想这就给我留下了一个问题:“为什么没有在zookeeper中填写端点?”
有什么想法吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题