风暴拓扑生成异常答案

【问题标题】：Storm Topology generating an exception风暴拓扑生成异常
【发布时间】：2016-09-18 11:15:20
【问题描述】：

我正在尝试使用 Storm spout 作为 Kafka 消费者将我的数据从 Kafka 主题发送到 HBase，并将数据发送到 HBase 我面临风暴拓扑中的异常......

java.lang.RuntimeException: java.lang.RuntimeException: No leader found for partition 0 at 
storm.kafka.DynamicBrokersReader.getBrokerInfo(DynamicBrokersReader.java:81)
at storm.kafka.trident.ZkBrokerReader.<init>(ZkBrokerReader.java:42) at storm.kafka.KafkaUtils.makeBrokerReader(KafkaUtils.java:57) 
at storm.kafka.KafkaSpout.open(KafkaSpout.java:87) at backtype.storm.daemon.executor$fn__5629$fn__5644.invoke(executor.clj:542) 
at backtype.storm.util$async_loop$fn__452.invoke(util.clj:463) 
at clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.RuntimeException: No leader found for partition 0 
at storm.kafka.DynamicBrokersReader.getLeaderFor(DynamicBrokersReader.java:120) 
at storm.kafka.DynamicBrokersReader.getBrokerInfo(DynamicBrokersReader.java:68) ... 7 more

【问题讨论】：

标签： hadoop apache-storm

【解决方案1】：

您的 kafka 主题有问题。第一行：

No leader found for partition 0

是这里的关键。

您将不得不深入研究 kafka 并修复该主题，以便它有一个充当领导者的代理。

【讨论】：