我在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中填写端点?”
有什么想法吗?
暂无答案!
目前还没有任何答案,快来回答吧!