Apoorv Mittal created KAFKA-17463:
-------------------------------------
Summary: 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
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)
