[ https://issues.apache.org/jira/browse/KAFKA-877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jay Kreps resolved KAFKA-877. ----------------------------- Resolution: Cannot Reproduce Will reopen if it reoccurs. > Still getting kafka.common.NotLeaderForPartitionException > --------------------------------------------------------- > > Key: KAFKA-877 > URL: https://issues.apache.org/jira/browse/KAFKA-877 > Project: Kafka > Issue Type: Bug > Affects Versions: 0.8 > Environment: DEV > Reporter: BalajiSeshadri > Priority: Blocker > Attachments: KAFKA-816.jpg > > > Using the below trunk and i still see error happening.Please let us know if > this can be fixed. > https://github.com/apache/kafka.git > [2013-04-25 16:47:08,924] WARN > [console-consumer-24019_MERD7-21964-1366930009136-8b7f9eb7-leader-finder-thread], > Failed to add fetcher for [mytopic,0] to broker > id:0,host:MERD7-21964.echostar.com,port:9092 > (kafka.consumer.ConsumerFetcherManager$$anon$1) > 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:525) > at java.lang.Class.newInstance0(Class.java:372) > at java.lang.Class.newInstance(Class.java:325) > at kafka.common.ErrorMapping$.exceptionFor(ErrorMapping.scala:72) > at > kafka.consumer.SimpleConsumer.earliestOrLatestOffset(SimpleConsumer.scala:163) > at > kafka.consumer.ConsumerFetcherThread.handleOffsetOutOfRange(ConsumerFetcherThread.scala:61) > at > kafka.server.AbstractFetcherThread.addPartition(AbstractFetcherThread.scala:167) > at > kafka.server.AbstractFetcherManager.addFetcher(AbstractFetcherManager.scala:48) > at > kafka.consumer.ConsumerFetcherManager$$anon$1$$anonfun$doWork$3.apply(ConsumerFetcherManager.scala:79) > at > kafka.consumer.ConsumerFetcherManager$$anon$1$$anonfun$doWork$3.apply(ConsumerFetcherManager.scala:75) > at > scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) > at > scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) > at scala.collection.Iterator$class.foreach(Iterator.scala:772) > at > scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) > at > scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) > at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) > at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) > at > kafka.consumer.ConsumerFetcherManager$$anon$1.doWork(ConsumerFetcherManager.scala:75) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) > We are evaluating Kafka for our new messaging system and we had tough time > running in windows. > We somehow managed to run 0.8 using cygwin but when we run the console > producer/consumer,we are not getting messages from consumer. > Please help us to fix this issue,this might not be related but its keeping on > throwing this error on consumer side. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira