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

Kafka server throws UnknownTopicOrPartitionException right after becoming leader for a new partition

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Won't Fix
    • 0.8.0
    • None
    • replication

    Description

      2013/03/05 01:24:01.207 INFO [ReplicaManager] [kafka-request-handler-5] [kafka] [] Replica Manager on Broker 273: Completed leader and isr request Name: LeaderAndIsrRequest; Version: 0; CorrelationId: 15
      38; ClientId: ; AckTimeoutMs: 1000 ms; ControllerEpoch: 3; PartitionStateInfo: (foo,7) -> PartitionStateInfo(LeaderIsrAndControllerEpoch(

      { "ISR":"273,271", "leader":"273", "leaderEpoch":"0" }

      ,3),2),(foo,4) -> PartitionStateInfo(LeaderIsrAndControllerEpoch(

      { "ISR":"270,273", "leader":"270", "leaderEpoch":"0" }

      ,3),2),(foo,1) -> PartitionStateInfo(LeaderIsrAndControllerEpoch(

      { "ISR":"273,270", "leader":"273", "leaderEpoch":"0" }

      ,3),2); Leaders: id:270,host:host270,port:10251,id:273,host:host273
      ,port:10251
      2013/03/05 01:24:01.473 INFO [Processor] [kafka-processor-10251-4] [kafka] [] Closing socket connection to /172.20.72.66.
      2013/03/05 01:24:01.505 INFO [Processor] [kafka-processor-10251-4] [kafka] [] Closing socket connection to /172.20.72.244.
      2013/03/05 01:24:01.521 INFO [Processor] [kafka-processor-10251-5] [kafka] [] Closing socket connection to /172.20.72.243.
      2013/03/05 01:24:01.555 INFO [Processor] [kafka-processor-10251-3] [kafka] [] Closing socket connection to /172.20.72.11.
      2013/03/05 01:24:01.568 INFO [Processor] [kafka-processor-10251-1] [kafka] [] Closing socket connection to /172.20.72.66.
      2013/03/05 01:24:01.606 INFO [Processor] [kafka-processor-10251-0] [kafka] [] Closing socket connection to /172.20.72.66.
      2013/03/05 01:24:01.758 INFO [Processor] [kafka-processor-10251-0] [kafka] [] Closing socket connection to /172.20.72.66.
      2013/03/05 01:24:01.776 ERROR [KafkaApis] [kafka-request-handler-7] [kafka] [] [KafkaApi-273] error when processing request (foo,1,0,1048576)
      kafka.common.UnknownTopicOrPartitionException: Topic foo partition 1 doesn't exist on 273
      at kafka.server.ReplicaManager.getLeaderReplicaIfLocal(ReplicaManager.scala:170)
      at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:301)
      at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:268)
      at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:264)
      at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
      at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
      at scala.collection.immutable.Map$Map2.foreach(Map.scala:127)
      at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
      at scala.collection.immutable.Map$Map2.map(Map.scala:110)
      at kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:264)
      at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:231)
      at kafka.server.KafkaApis.handle(KafkaApis.scala:61)
      at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:41)
      at java.lang.Thread.run(Thread.java:619)

      Attachments

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            nehanarkhede Neha Narkhede
            nehanarkhede Neha Narkhede
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment