Support Questions
Find answers, ask questions, and share your expertise

Kafka-Consumer Failed to add leader for partitions

New Contributor

i have installed HDP 2.5.3 version and using kafka in 3 brokers but i had stopped HDP cluster due to maintenance activity and later when i started cluster i am getting below kafka consumer errors. please help me

metadata.broker.list=hnode3.com:6667,hnode1.com:6667,hnode2.com:6667, request.timeout.ms=30000, client.id=console-consumer-85300, security.protocol=PLAINTEXT} [2018-11-23 11:43:41,711] WARN [console-consumer-85300_hnode2.com-1542953611274-fa71af73-leader-finder-thread], Failed to add leader for partitions [firsttopic1,1],[firsttopic1,0]; will retry (kafka.consumer.ConsumerFetcherManager$LeaderFinderThread) kafka.common.NotLeaderForPartitionException at sun.reflect.GeneratedConstructorAccessor1.newInstance(Unknown Source) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at java.lang.Class.newInstance(Class.java:442) at kafka.common.ErrorMapping$.exceptionFor(ErrorMapping.scala:105) at kafka.consumer.SimpleConsumer.earliestOrLatestOffset(SimpleConsumer.scala:207) at kafka.consumer.ConsumerFetcherThread.handleOffsetOutOfRange(ConsumerFetcherThread.scala:86) at kafka.server.AbstractFetcherThread$anonfun$addPartitions$2.apply(AbstractFetcherThread.scala:192) at kafka.server.AbstractFetcherThread$anonfun$addPartitions$2.apply(AbstractFetcherThread.scala:187) at scala.collection.TraversableLike$WithFilter$anonfun$foreach$1.apply(TraversableLike.scala:772) at scala.collection.immutable.Map$Map1.foreach(Map.scala:109) at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771) at kafka.server.AbstractFetcherThread.addPartitions(AbstractFetcherThread.scala:187) at kafka.server.AbstractFetcherManager$anonfun$addFetcherForPartitions$2.apply(AbstractFetcherManager.scala:88) at kafka.server.AbstractFetcherManager$anonfun$addFetcherForPartitions$2.apply(AbstractFetcherManager.scala:78) at scala.collection.TraversableLike$WithFilter$anonfun$foreach$1.apply(TraversableLike.scala:772) at scala.collection.immutable.Map$Map2.foreach(Map.scala:130) at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771) at kafka.server.AbstractFetcherManager.addFetcherForPartitions(AbstractFetcherManager.scala:78) at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:97) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

0 REPLIES 0