Can you guys help me on this ?.Getting below error on High Level consumer.But 
topic does exist.

{2013-07-31 11:52:57,176} WARN  
[UNITTEST_MERD7-181710-1375293172238-5f1b0917-leader-finder-thread] 
(Logging.scala:88) - 
[UNITTEST_MERD7-181710-1375293172238-5f1b0917-leader-finder-thread], Failed to 
find leader for Set([unittest2x2,1], [unittest2x2,0])
java.util.IllegalFormatConversionException: d != java.lang.String
       at 
java.util.Formatter$FormatSpecifier.failConversion(Formatter.java:3999)
       at java.util.Formatter$FormatSpecifier.printInteger(Formatter.java:2709)
       at java.util.Formatter$FormatSpecifier.print(Formatter.java:2661)
       at java.util.Formatter.format(Formatter.java:2433)
       at java.util.Formatter.format(Formatter.java:2367)
       at java.lang.String.format(String.java:2769)
       at 
scala.collection.immutable.StringLike$class.format(StringLike.scala:251)
       at scala.collection.immutable.StringOps.format(StringOps.scala:31)
       at 
kafka.api.TopicMetadata$$anonfun$toString$1.apply(TopicMetadata.scala:67)
       at 
kafka.api.TopicMetadata$$anonfun$toString$1.apply(TopicMetadata.scala:64)
       at 
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
       at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
       at kafka.api.TopicMetadata.toString(TopicMetadata.scala:64)
       at 
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread$$anonfun$doWork$3$$anonfun$apply$1.apply(ConsumerFetcherManager.scala:68)
       at 
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread$$anonfun$doWork$3$$anonfun$apply$1.apply(ConsumerFetcherManager.scala:68)
       at kafka.utils.Logging$class.debug(Logging.scala:51)
       at kafka.utils.ShutdownableThread.debug(ShutdownableThread.scala:23)
       at 
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread$$anonfun$doWork$3.apply(ConsumerFetcherManager.scala:68)
       at 
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread$$anonfun$doWork$3.apply(ConsumerFetcherManager.scala:68)
       at scala.collection.Iterator$class.foreach(Iterator.scala:631)
       at scala.collection.immutable.VectorIterator.foreach(Vector.scala:605)
       at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
       at scala.collection.immutable.Vector.foreach(Vector.scala:36)
       at 
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:68)
       at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)


I see the topic in broker but still consumption fails.

Thanks,

Balaji

Reply via email to