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

Flaky Test AdminClientIntegrationTest#testConsumerGroups

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Critical
    • Resolution: Fixed
    • 2.3.0
    • 2.7.0
    • core, unit tests

    Description

      https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk8/detail/kafka-trunk-jdk8/3459/tests

      java.lang.AssertionError: expected:<2> but was:<0>
      at org.junit.Assert.fail(Assert.java:89)
      at org.junit.Assert.failNotEquals(Assert.java:835)
      at org.junit.Assert.assertEquals(Assert.java:647)
      at org.junit.Assert.assertEquals(Assert.java:633)
      at kafka.api.AdminClientIntegrationTest.testConsumerGroups(AdminClientIntegrationTest.scala:1194)

      STDOUT

      2019-03-12 10:52:33,482] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:52:33,485] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:52:35,880] WARN Unable to read additional data from client sessionid 0x104458575770003, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
      [2019-03-12 10:52:38,596] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition elect-preferred-leaders-topic-1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:52:38,797] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition elect-preferred-leaders-topic-2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:52:51,998] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:52:52,005] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:13,750] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition mytopic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:13,754] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition mytopic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:13,755] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition mytopic2-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:13,760] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition mytopic2-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:13,757] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition mytopic2-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:13,769] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition mytopic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:13,778] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition mytopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:15,062] WARN Unable to read additional data from client sessionid 0x104458612980000, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
      [2019-03-12 10:53:15,859] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:32,050] ERROR [ReplicaManager broker=1] Error while changing replica dir for partition topic-0 (kafka.server.ReplicaManager:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: Partition topic-0 doesn't exist
      [2019-03-12 10:53:32,051] ERROR [ReplicaManager broker=0] Error while changing replica dir for partition topic-0 (kafka.server.ReplicaManager:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: Partition topic-0 doesn't exist
      [2019-03-12 10:53:32,051] ERROR [ReplicaManager broker=2] Error while changing replica dir for partition topic-0 (kafka.server.ReplicaManager:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: Partition topic-0 doesn't exist
      [2019-03-12 10:53:32,070] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:32,071] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:37,282] WARN Unable to read additional data from client sessionid 0x10445865a3c0000, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
      [2019-03-12 10:53:38,078] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:47,346] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition mytopic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:47,347] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition mytopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:47,354] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition mytopic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:55,839] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition create-partitions-topic-2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:53:56,091] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition create-partitions-topic-2-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:01,865] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition mytopic-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:01,872] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition mytopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:01,873] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition mytopic-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:01,878] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition mytopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:06,768] WARN Unable to read additional data from client sessionid 0x1044586ce900002, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
      [2019-03-12 10:54:13,130] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:17,295] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:17,303] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:25,436] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:25,439] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-03-12 10:54:25,458] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.

      STDERR

      Exception in thread "Thread-2316" org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
      at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeThrowInterruptException(ConsumerNetworkClient.java:495)
      at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:278)
      at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
      at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:212)
      at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.fetchCommittedOffsets(ConsumerCoordinator.java:541)
      at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.refreshCommittedOffsetsIfNeeded(ConsumerCoordinator.java:500)
      at org.apache.kafka.clients.consumer.KafkaConsumer.updateFetchPositions(KafkaConsumer.java:2207)
      at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1233)
      at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1198)
      at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1138)
      at kafka.api.AdminClientIntegrationTest$$anon$1.run(AdminClientIntegrationTest.scala:1167)
      Caused by: java.lang.InterruptedException
      ... 11 more

      Attachments

        Issue Links

          duplicates

          Bug - A problem which impairs or prevents the functions of the product. KAFKA-7978 Flaky Test SaslSslAdminClientIntegrationTest#testConsumerGroups

          • Critical - Crashes, loss of data, severe memory leak.
          • Closed
          links to

          Web Link GitHub Pull Request #6441

          Web Link GitHub Pull Request #6474

          Web Link GitHub Pull Request #9062

          Activity

            People

              showuon Luke Chen
              mjsax Matthias J. Sax
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: