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)
