[
https://issues.apache.org/jira/browse/KAFKA-17463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879512#comment-17879512
]
Apoorv Mittal commented on KAFKA-17463:
---------------------------------------
I ran the tests repeatedly for 100 times and it didn't fail. Seem nothing wrong
with the test.
> 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
>
> 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)
