Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2054 Fix Kafka transient unit test failures
  3. KAFKA-4196

Transient test failure: DeleteConsumerGroupTest.testConsumptionOnRecreatedTopicAfterTopicWideDeleteInZK

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Resolved
    • Priority: Major
    • Resolution: Auto Closed
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: None

      Description

      The error:

      java.lang.AssertionError: Admin path /admin/delete_topic/topic path not deleted even after a replica is restarted
      	at org.junit.Assert.fail(Assert.java:88)
      	at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:752)
      	at kafka.utils.TestUtils$.verifyTopicDeletion(TestUtils.scala:1017)
      	at kafka.admin.DeleteConsumerGroupTest.testConsumptionOnRecreatedTopicAfterTopicWideDeleteInZK(DeleteConsumerGroupTest.scala:156)
      

      Caused by a broken invariant in the Controller: a partition exists in `ControllerContext.partitionLeadershipInfo`, but not `controllerContext.partitionReplicaAssignment`.

      [2016-09-20 06:45:13,967] ERROR [BrokerChangeListener on Controller 1]: Error while handling broker changes (kafka.controller.ReplicaStateMachine$BrokerChangeListener:103)
      java.util.NoSuchElementException: key not found: [topic,0]
      	at scala.collection.MapLike$class.default(MapLike.scala:228)
      	at scala.collection.AbstractMap.default(Map.scala:58)
      	at scala.collection.mutable.HashMap.apply(HashMap.scala:64)
      	at kafka.controller.ControllerBrokerRequestBatch.kafka$controller$ControllerBrokerRequestBatch$$updateMetadataRequestMapFor$1(ControllerChannelManager.scala:310)
      	at kafka.controller.ControllerBrokerRequestBatch$$anonfun$addUpdateMetadataRequestForBrokers$4.apply(ControllerChannelManager.scala:343)
      	at kafka.controller.ControllerBrokerRequestBatch$$anonfun$addUpdateMetadataRequestForBrokers$4.apply(ControllerChannelManager.scala:343)
      	at scala.collection.mutable.HashSet.foreach(HashSet.scala:79)
      	at kafka.controller.ControllerBrokerRequestBatch.addUpdateMetadataRequestForBrokers(ControllerChannelManager.scala:343)
      	at kafka.controller.KafkaController.sendUpdateMetadataRequest(KafkaController.scala:1030)
      	at kafka.controller.KafkaController.onBrokerFailure(KafkaController.scala:492)
      	at kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ReplicaStateMachine.scala:376)
      	at kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1$$anonfun$apply$mcV$sp$1.apply(ReplicaStateMachine.scala:358)
      	at kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1$$anonfun$apply$mcV$sp$1.apply(ReplicaStateMachine.scala:358)
      	at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
      	at kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1.apply$mcV$sp(ReplicaStateMachine.scala:357)
      	at kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1.apply(ReplicaStateMachine.scala:356)
      	at kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1.apply(ReplicaStateMachine.scala:356)
      	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:234)
      	at kafka.controller.ReplicaStateMachine$BrokerChangeListener.handleChildChange(ReplicaStateMachine.scala:355)
      	at org.I0Itec.zkclient.ZkClient$10.run(ZkClient.java:843)
      	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                ijuma Ismael Juma
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: