Re: Unable to consume data because of below issue

[Jun Rao <ju...@gmail.com>]

It seems that you turned on debug level logging and hit a format error
during logging. Are you using the 0.8 beta1 release? I enabled logging
there and didn't see that error.

Thanks,

Jun


On Wed, Jul 31, 2013 at 10:56 AM, Seshadri, Balaji <Balaji.Seshadri@dish.com
> wrote:

> 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
>