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