Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-877

Still getting kafka.common.NotLeaderForPartitionException

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Blocker
    • Resolution: Cannot Reproduce
    • Affects Version/s: 0.8.0
    • Fix Version/s: None
    • Component/s: None
    • Labels:
      None
    • Environment:
      DEV

      Description

      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.

        Attachments

        1. KAFKA-816.jpg
          62 kB
          BalajiSeshadri

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                balaji.seshadri@dish.com BalajiSeshadri
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: