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