Andrew Schofield created KAFKA-16184:
----------------------------------------

             Summary: Flaky test - testAlterReplicaLogDirs(String).quorum=kraft 
– kafka.api.PlaintextAdminIntegrationTest
                 Key: KAFKA-16184
                 URL: https://issues.apache.org/jira/browse/KAFKA-16184
             Project: Kafka
          Issue Type: Bug
            Reporter: Andrew Schofield


[https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15214/1/tests/]
h4. Error
org.opentest4j.AssertionFailedError: timed out waiting for replica movement
h4. Stacktrace
org.opentest4j.AssertionFailedError: timed out waiting for replica movement
 at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38)
 at org.junit.jupiter.api.Assertions.fail(Assertions.java:134)
 at 
kafka.api.PlaintextAdminIntegrationTest.$anonfun$testAlterReplicaLogDirs$7(PlaintextAdminIntegrationTest.scala:317)
 at 
kafka.api.PlaintextAdminIntegrationTest.$anonfun$testAlterReplicaLogDirs$7$adapted(PlaintextAdminIntegrationTest.scala:316)
 at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62)
 at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55)
 at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49)
 at 
kafka.api.PlaintextAdminIntegrationTest.testAlterReplicaLogDirs(PlaintextAdminIntegrationTest.scala:316)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
 at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 at java.lang.reflect.Method.invoke(Method.java:498)
 at 
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
 at 
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
 at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
 at 
org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:45)
 at 
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
 at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
 at 
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
 at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
 at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
 at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
 at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
 at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
 at 
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
 at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
 at 
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
 at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:218)
 at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
 at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:214)
 at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:139)
 at 
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:69)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
 at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
 at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
 at 
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
 at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
 at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
 at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
 at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
 at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
 at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
 at 
java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
 at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
 at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
 at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
 at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
 at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
 at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
 at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
 at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
 at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
 at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
 at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
 at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
 at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
 at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
 at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
 at 
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
 at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
 at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
 at 
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
 at 
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
 at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
 at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
 at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
 at 
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
 at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
 at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
 at java.util.ArrayList.forEach(ArrayList.java:1259)
 at 
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
 at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
 at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
 at java.util.ArrayList.forEach(ArrayList.java:1259)
 at 
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
 at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
 at 
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
 at 
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
 at 
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
 at 
org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
 at 
org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
 at 
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
 at 
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
 at 
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
 at 
org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
 at 
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
 at 
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
 at 
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
 at 
org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
 at 
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:119)
 at 
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:94)
 at 
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:89)
 at 
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:62)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
 at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 at java.lang.reflect.Method.invoke(Method.java:498)
 at 
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
 at 
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
 at 
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
 at 
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
 at com.sun.proxy.$Proxy2.stop(Unknown Source)
 at 
org.gradle.api.internal.tasks.testing.worker.TestWorker$3.run(TestWorker.java:193)
 at 
org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
 at 
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
 at 
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
 at 
org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
 at 
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:113)
 at 
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:65)
 at 
worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
 at 
worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
h4. Standard Output
[2024-01-17 17:02:53,177] WARN maxCnxns is not configured, using default value 
0. (org.apache.zookeeper.server.ServerCnxnFactory:309)
[2024-01-17 17:02:55,901] 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-01-17 17:02:55,919] 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-01-17 17:02:55,929] 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-01-17 17:02:55,997] 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-01-17 17:02:56,308] WARN [ReplicaFetcher replicaId=1, leaderId=0, 
fetcherId=0] Received UNKNOWN_TOPIC_OR_PARTITION 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-01-17 17:02:56,309] WARN [ReplicaFetcher replicaId=2, leaderId=0, 
fetcherId=0] Received UNKNOWN_TOPIC_OR_PARTITION 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-01-17 17:02:56,322] 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-01-17 17:02:56,329] 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-01-17 17:02:57,868] WARN [ReplicaFetcher replicaId=0, leaderId=2, 
fetcherId=0] Received UNKNOWN_TOPIC_OR_PARTITION 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-01-17 17:02:58,029] 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)]),StopReplicaTopicState(topicName='mytopic3', 
partitionStates=[StopReplicaPartitionState(partitionIndex=0, leaderEpoch=-2, 
deletePartition=true)])) to broker localhost:36389 (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:258)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,045] WARN [RequestSendThread controllerId=0] Controller 0 
epoch 1 fails to send request (type=StopReplicaRequest, controllerId=0, 
controllerEpoch=1, brokerEpoch=46, deletePartitions=false, 
topicStates=StopReplicaTopicState(topicName='mytopic', 
partitionStates=[StopReplicaPartitionState(partitionIndex=0, leaderEpoch=-2, 
deletePartition=false)])) to broker localhost:33071 (id: 1 rack: null). 
Reconnecting to broker. (kafka.controller.RequestSendThread: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.controller.RequestSendThread.doWork(ControllerChannelManager.scala:258)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,045] 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='mytopic', 
partitionStates=[StopReplicaPartitionState(partitionIndex=0, leaderEpoch=-2, 
deletePartition=true), StopReplicaPartitionState(partitionIndex=1, 
leaderEpoch=-2, deletePartition=true)])) to broker localhost:33663 (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:258)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,130] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,131] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,146] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,147] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33071 (id: 1 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33071 (id: 1 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,155] WARN [Controller id=0, targetBrokerId=2] Connection 
to node 2 (localhost/127.0.0.1:33663) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,155] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33663 (id: 2 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33663 (id: 2 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,232] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,232] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,248] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,249] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33071 (id: 1 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33071 (id: 1 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,257] WARN [Controller id=0, targetBrokerId=2] Connection 
to node 2 (localhost/127.0.0.1:33663) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,257] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33663 (id: 2 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33663 (id: 2 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,333] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,334] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,350] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,350] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33071 (id: 1 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33071 (id: 1 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,358] WARN [Controller id=0, targetBrokerId=2] Connection 
to node 2 (localhost/127.0.0.1:33663) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,358] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33663 (id: 2 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33663 (id: 2 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,435] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,435] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,452] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,452] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33071 (id: 1 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33071 (id: 1 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,459] WARN [Controller id=0, targetBrokerId=2] Connection 
to node 2 (localhost/127.0.0.1:33663) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,460] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33663 (id: 2 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33663 (id: 2 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,537] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,537] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,553] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,553] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33071 (id: 1 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33071 (id: 1 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,561] WARN [Controller id=0, targetBrokerId=2] Connection 
to node 2 (localhost/127.0.0.1:33663) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,561] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33663 (id: 2 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33663 (id: 2 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,638] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,638] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,654] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,655] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33071 (id: 1 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33071 (id: 1 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,662] WARN [Controller id=0, targetBrokerId=2] Connection 
to node 2 (localhost/127.0.0.1:33663) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,662] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33663 (id: 2 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33663 (id: 2 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,739] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,740] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,756] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,756] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33071 (id: 1 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33071 (id: 1 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,763] WARN [Controller id=0, targetBrokerId=2] Connection 
to node 2 (localhost/127.0.0.1:33663) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,763] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33663 (id: 2 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33663 (id: 2 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,840] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,841] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,857] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,857] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33071 (id: 1 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33071 (id: 1 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,864] WARN [Controller id=0, targetBrokerId=2] Connection 
to node 2 (localhost/127.0.0.1:33663) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,864] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33663 (id: 2 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33663 (id: 2 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,942] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,942] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,958] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,958] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33071 (id: 1 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33071 (id: 1 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:58,965] WARN [Controller id=0, targetBrokerId=2] Connection 
to node 2 (localhost/127.0.0.1:33663) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:58,965] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:33663 (id: 2 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:33663 (id: 2 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:59,043] WARN [Controller id=0, targetBrokerId=0] Connection 
to node 0 (localhost/127.0.0.1:36389) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:59,043] WARN [RequestSendThread controllerId=0] Controller 
0's connection to broker localhost:36389 (id: 0 rack: null) was unsuccessful 
(kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36389 (id: 0 rack: null) failed.
 at 
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
 at 
kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
 at 
kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
 at 
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2024-01-17 17:02:59,059] WARN [Controller id=0, targetBrokerId=1] Connection 
to node 1 (localhost/127.0.0.1:33071) could not be established. Node may not be 
available. (org.apache.kafka.clients.NetworkClient:830)
[2024-01-17 17:02:59,059] WARN [RequestSendThread controllerId=0] Cont



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to