[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171250#comment-17171250 ]
Luke Chen commented on KAFKA-8098: ---------------------------------- [https://builds.apache.org/blue/rest/organizations/jenkins/pipelines/kafka-trunk-jdk11/runs/1688/log/?start=0] > Flaky Test AdminClientIntegrationTest#testConsumerGroups > -------------------------------------------------------- > > Key: KAFKA-8098 > URL: https://issues.apache.org/jira/browse/KAFKA-8098 > Project: Kafka > Issue Type: Bug > Components: core, unit tests > Affects Versions: 2.3.0 > Reporter: Matthias J. Sax > Assignee: Luke Chen > Priority: Critical > Labels: flaky-test > Fix For: 2.3.0, 2.2.1 > > > [https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk8/detail/kafka-trunk-jdk8/3459/tests] > {quote}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){quote} > STDOUT > {quote}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.{quote} > STDERR > {quote}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{quote} -- This message was sent by Atlassian Jira (v8.3.4#803005)