我正在尝试将数据从kafka主题发送到hbase，使用storm spout作为kafka使用者并将数据发送到hbase我在storm拓扑中遇到异常。。。。
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
1条答案
按热度按时间lyfkaqu11#
你的Kafka主题有问题。第一行：
钥匙在这里。
你必须深入研究Kafka并解决这个问题，这样它就有了一个充当领导者的经纪人。