kafka.common.UnknownTopicOrPartitionException

kafka-users | Jun Rao | 2 years ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    Re: Topic in bad state after controller to broker messaging fails

    kafka-users | 2 years ago | Jun Rao
    kafka.common.UnknownTopicOrPartitionException

    Root Cause Analysis

    1. kafka.common.UnknownTopicOrPartitionException

      No message provided

      at sun.reflect.NativeConstructorAccessorImpl.newInstance0()
    2. Java RT
      Class.newInstance
      1. sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
      2. sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
      3. sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
      4. java.lang.reflect.Constructor.newInstance(Constructor.java:525)
      5. java.lang.Class.newInstance0(Class.java:372)
      6. java.lang.Class.newInstance(Class.java:325)
      6 frames
    3. Apache Kafka
      AbstractFetcherThread$$anonfun$addPartitions$2.apply
      1. kafka.common.ErrorMapping$.exceptionFor(ErrorMapping.scala:86)
      2. kafka.consumer.SimpleConsumer.earliestOrLatestOffset(SimpleConsumer.scala:168)
      3. kafka.consumer.ConsumerFetcherThread.handleOffsetOutOfRange(ConsumerFetcherThread.scala:60)
      4. kafka.server.AbstractFetcherThread$$anonfun$addPartitions$2.apply(AbstractFetcherThread.scala:180)
      5. kafka.server.AbstractFetcherThread$$anonfun$addPartitions$2.apply(AbstractFetcherThread.scala:175)
      5 frames
    4. Scala
      TraversableLike$WithFilter.foreach
      1. scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772)
      2. scala.collection.immutable.Map$Map1.foreach(Map.scala:109)
      3. scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771)
      3 frames
    5. Apache Kafka
      AbstractFetcherManager$$anonfun$addFetcherForPartitions$2.apply
      1. kafka.server.AbstractFetcherThread.addPartitions(AbstractFetcherThread.scala:175)
      2. kafka.server.AbstractFetcherManager$$anonfun$addFetcherForPartitions$2.apply(AbstractFetcherManager.scala:86)
      3. kafka.server.AbstractFetcherManager$$anonfun$addFetcherForPartitions$2.apply(AbstractFetcherManager.scala:76)
      3 frames
    6. Scala
      TraversableLike$WithFilter.foreach
      1. scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772)
      2. scala.collection.immutable.Map$Map1.foreach(Map.scala:109)
      3. scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:771)
      3 frames
    7. Apache Kafka
      ShutdownableThread.run
      1. kafka.server.AbstractFetcherManager.addFetcherForPartitions(AbstractFetcherManager.scala:76)
      2. kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:95)
      3. kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60)
      3 frames