Сторм Топология генерируя исключение

Question

Я пытаюсь т отправить свои данные в 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 

Answer 1

Что-то не так с вашей темой kafka. Первая строка:

No leader found for partition 0 

является ключевым здесь.

Вам нужно будет впасть в кафку и исправить эту тему, чтобы у нее был брокер, действующий как лидер.