[
https://issues.apache.org/jira/browse/KAFKA-17463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-17463:
----------------------------------
Description:
Test has been failing consistent hence moving from flaky:
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}
was:
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}
> 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 consistent hence moving from flaky:
> 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)
