[
https://issues.apache.org/jira/browse/KAFKA-17463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894553#comment-17894553
]
David Arthur commented on KAFKA-17463:
--------------------------------------
This has regressed on trunk
https://ge.apache.org/scans/tests?search.names=CI%20workflow%2CGit%20repository&search.rootProjectNames=kafka&search.tags=github%2Ctrunk&search.tasks=quarantinedTest%2Ctest&search.timeZoneId=America%2FNew_York&search.values=CI%2Chttps:%2F%2Fgithub.com%2Fapache%2Fkafka&tests.container=kafka.api.PlaintextAdminIntegrationTest
> Flaky test:
> kafka.api.PlaintextAdminIntegrationTest."testShareGroups(String).quorum=kraft+kip932"
> -------------------------------------------------------------------------------------------------
>
> Key: KAFKA-17463
> URL: https://issues.apache.org/jira/browse/KAFKA-17463
> Project: Kafka
> Issue Type: Bug
> Reporter: Apoorv Mittal
> Priority: Major
>
> Test has been failing for multiple runs now:
> [https://github.com/apache/kafka/actions/runs/11565459184/job/32192682732?pr=16842]
>
> {code:java}
> org.opentest4j.AssertionFailedError: expected: <true> but was: <false>
> at
> app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
> at
> app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
> at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
> at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36)
> at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:31)
> at app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:183)
> at
> app//kafka.api.PlaintextAdminIntegrationTest.testShareGroups(PlaintextAdminIntegrationTest.scala:2151)
> at [email protected]/java.lang.reflect.Method.invoke(Method.java:580)
> at
> [email protected]/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
> at
> [email protected]/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:215)
> at
> [email protected]/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:197)
> at
> [email protected]/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:215)
> at
> [email protected]/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
> at
> [email protected]/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:215)
> at
> [email protected]/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:215)
> at
> [email protected]/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:215)
> at
> [email protected]/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
> at
> [email protected]/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:215)
> at
> [email protected]/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:1024)
> at
> [email protected]/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:570)
> at
> [email protected]/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:560)
> at
> [email protected]/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
> at
> [email protected]/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
> at
> [email protected]/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:265)
> at
> [email protected]/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:636)
> at
> [email protected]/java.util.stream.ReferencePipeline$7$1FlatMap.accept(ReferencePipeline.java:294)
> at
> [email protected]/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:215)
> at
> [email protected]/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:215)
> at
> [email protected]/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:215)
> at
> [email protected]/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1709)
> at
> [email protected]/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:570)
> at
> [email protected]/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:560)
> at
> [email protected]/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
> at
> [email protected]/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
> at
> [email protected]/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:265)
> at
> [email protected]/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:636)
> at
> [email protected]/java.util.stream.ReferencePipeline$7$1FlatMap.accept(ReferencePipeline.java:294)
> at
> [email protected]/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1709)
> at
> [email protected]/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:570)
> at
> [email protected]/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:560)
> at
> [email protected]/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
> at
> [email protected]/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
> at
> [email protected]/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:265)
> at
> [email protected]/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:636)
> at [email protected]/java.util.ArrayList.forEach(ArrayList.java:1597)
> at [email protected]/java.util.ArrayList.forEach(ArrayList.java:1597)
> {code}
> -----------------------------------------------------------------------------------------------------------------
> Tested locally and test passed but failed on CI.
> [https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-16956/5/testReport/kafka.api/PlaintextAdminIntegrationTest/Build___JDK_8_and_Scala_2_12____testShareGroups_String__quorum_kraft_kip932_/]
>
> {code:java}
> [2024-08-30 23:28:16,679] WARN maxCnxns is not configured, using default
> value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309)
> [2024-08-30 23:28:18,306] WARN Setting entity configs without any checks on
> the controller. (kafka.zk.KafkaZkClient:500)
> [2024-08-30 23:28:19,243] WARN [ReplicaFetcher replicaId=0, leaderId=2,
> fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition
> mytopic2-2. This error may be returned transiently when the partition is
> being created or deleted, but it is not expected to persist.
> (kafka.server.ReplicaFetcherThread:70)
> [2024-08-30 23:28:19,244] WARN [ReplicaFetcher replicaId=0, leaderId=1,
> fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition
> mytopic2-0. This error may be returned transiently when the partition is
> being created or deleted, but it is not expected to persist.
> (kafka.server.ReplicaFetcherThread:70)
> [2024-08-30 23:28:19,249] WARN [ReplicaFetcher replicaId=0, leaderId=2,
> fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition
> mytopic-1. This error may be returned transiently when the partition is being
> created or deleted, but it is not expected to persist.
> (kafka.server.ReplicaFetcherThread:70)
> [2024-08-30 23:28:19,437] WARN [ReplicaFetcher replicaId=2, leaderId=0,
> fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition
> mytopic2-1. This error may be returned transiently when the partition is
> being created or deleted, but it is not expected to persist.
> (kafka.server.ReplicaFetcherThread:70)
> [2024-08-30 23:28:19,438] WARN [ReplicaFetcher replicaId=2, leaderId=1,
> fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition
> mytopic2-0. This error may be returned transiently when the partition is
> being created or deleted, but it is not expected to persist.
> (kafka.server.ReplicaFetcherThread:70)
> [2024-08-30 23:28:19,440] WARN [ReplicaFetcher replicaId=1, leaderId=0,
> fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition
> mytopic2-1. This error may be returned transiently when the partition is
> being created or deleted, but it is not expected to persist.
> (kafka.server.ReplicaFetcherThread:70)
> [2024-08-30 23:28:19,743] WARN [ReplicaFetcher replicaId=2, leaderId=1,
> fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition
> mytopic-0. This error may be returned transiently when the partition is being
> created or deleted, but it is not expected to persist.
> (kafka.server.ReplicaFetcherThread:70)
> [2024-08-30 23:28:19,749] WARN [ReplicaFetcher replicaId=1, leaderId=2,
> fetcherId=0] Received UNKNOWN_TOPIC_OR_PARTITION from the leader for
> partition mytopic2-2. This error may be returned transiently when the
> partition is being created or deleted, but it is not expected to persist.
> (kafka.server.ReplicaFetcherThread:70)
> [2024-08-30 23:28:21,502] WARN [RequestSendThread controllerId=0] Controller
> 0 epoch 1 fails to send request (type=StopReplicaRequest, controllerId=0,
> controllerEpoch=1, brokerEpoch=26, deletePartitions=false,
> topicStates=StopReplicaTopicState(topicName='mytopic',
> partitionStates=[StopReplicaPartitionState(partitionIndex=1, leaderEpoch=-2,
> deletePartition=true)])) to broker localhost:38683 (id: 0 rack: null).
> Reconnecting to broker. (kafka.controller.RequestSendThread:72)
> java.io.IOException: Connection to 0 was disconnected before the response was
> read
> at
> org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100)
> at
> kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:259)
> at
> org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:136)
> [2024-08-30 23:28:21,503] WARN [ReplicaFetcher replicaId=2, leaderId=1,
> fetcherId=0] Error in response for fetch request (type=FetchRequest,
> replicaId=2, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
> isolationLevel=read_uncommitted, removed=, replaced=,
> metadata=(sessionId=1256110258, epoch=1), rackId=)
> (kafka.server.ReplicaFetcherThread:72)
> java.io.IOException: Connection to 1 was disconnected before the response was
> read
> at
> org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100)
> at
> kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:114)
> at
> kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
> at
> kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:318)
> at
> kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:132)
> at
> kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:131)
> at scala.Option.foreach(Option.scala:407)
> at
> kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:131)
> at
> kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114)
> at
> kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
> at
> org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:136)
> [2024-08-30 23:28:21,503] WARN [RequestSendThread controllerId=0] Controller
> 0 epoch 1 fails to send request (type=StopReplicaRequest, controllerId=0,
> controllerEpoch=1, brokerEpoch=62, deletePartitions=false,
> topicStates=StopReplicaTopicState(topicName='mytopic2',
> partitionStates=[StopReplicaPartitionState(partitionIndex=2, leaderEpoch=-2,
> deletePartition=true), StopReplicaPartitionState(partitionIndex=1,
> leaderEpoch=-2, deletePartition=true),
> StopReplicaPartitionState(partitionIndex=0, leaderEpoch=-2,
> deletePartition=true)])) to broker localhost:43783 (id: 2 rack: null).
> Reconnecting to broker. (kafka.controller.RequestSendThread:72)
> java.io.IOException: Connection to 2 was disconnected before the response was
> read
> at
> org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100)
> at
> kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:259)
> at
> org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:136)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
