Andrew Schofield created KAFKA-15932:
----------------------------------------
Summary: Flaky test -
PlaintextConsumerTest.testSeek("kraft+kip-848","consumer")
Key: KAFKA-15932
URL: https://issues.apache.org/jira/browse/KAFKA-15932
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 3.7.0
Reporter: Andrew Schofield
Intermittently failing test for the new consumer.
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14859/1/tests/
```Error
org.opentest4j.AssertionFailedError: Timed out before consuming expected 1
records. The number consumed was 0.
Stacktrace
org.opentest4j.AssertionFailedError: Timed out before consuming expected 1
records. The number consumed was 0.
at
app//org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38)
at app//org.junit.jupiter.api.Assertions.fail(Assertions.java:134)
at
app//kafka.api.AbstractConsumerTest.consumeRecords(AbstractConsumerTest.scala:161)
at
app//kafka.api.AbstractConsumerTest.consumeAndVerifyRecords(AbstractConsumerTest.scala:128)
at
app//kafka.api.PlaintextConsumerTest.testSeek(PlaintextConsumerTest.scala:616)
at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base@11.0.16.1/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base@11.0.16.1/java.lang.reflect.Method.invoke(Method.java:566)
at
app//org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
at
app//org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
app//org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at
app//org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
at
app//org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
at
app//org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:218)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:214)
at
app//org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:139)
at
app//org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:69)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at
app//org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at
app//org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
at
app//org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
at
app//org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
at
java.base@11.0.16.1/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:658)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:274)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
at
java.base@11.0.16.1/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at
java.base@11.0.16.1/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at
java.base@11.0.16.1/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.base@11.0.16.1/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at
java.base@11.0.16.1/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:274)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at
java.base@11.0.16.1/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655)
at
java.base@11.0.16.1/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at
java.base@11.0.16.1/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at
java.base@11.0.16.1/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.base@11.0.16.1/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at
java.base@11.0.16.1/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:274)
at
java.base@11.0.16.1/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655)
at
java.base@11.0.16.1/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at
java.base@11.0.16.1/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at
java.base@11.0.16.1/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.base@11.0.16.1/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at
java.base@11.0.16.1/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base@11.0.16.1/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
at
app//org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
at
app//org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at
app//org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.base@11.0.16.1/java.util.ArrayList.forEach(ArrayList.java:1541)
at
app//org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at
app//org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.base@11.0.16.1/java.util.ArrayList.forEach(ArrayList.java:1541)
at
app//org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at
app//org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
app//org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
app//org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at
app//org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at
app//org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at
app//org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
at
app//org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
at
app//org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at
app//org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at
app//org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at
app//org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at
app//org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
at
app//org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
at
app//org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:118)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:93)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:88)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:62)
at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
at
java.base@11.0.16.1/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base@11.0.16.1/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base@11.0.16.1/java.lang.reflect.Method.invoke(Method.java:566)
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
app//worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
at
app//worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
Standard Output
[2023-11-28 22:32:42,436] WARN maxCnxns is not configured, using default value
0. (org.apache.zookeeper.server.ServerCnxnFactory:309)
[2023-11-28 22:32:42,554] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition
__consumer_offsets-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)
[2023-11-28 22:32:42,554] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition
__consumer_offsets-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)
[2023-11-28 22:32:42,658] WARN [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition topic-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)
[2023-11-28 22:32:42,659] WARN [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition topic-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)
[2023-11-28 22:32:42,659] WARN [ReplicaFetcher replicaId=0, leaderId=2,
fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition topic-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)
[2023-11-28 22:32:44,062] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1029971141, epoch=2), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:44,062] WARN [ReplicaFetcher replicaId=2, leaderId=0,
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=258532250, epoch=2), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:44,282] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Close timed out with 1 pending requests to coordinator,
terminating client connections
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1123)
[2023-11-28 22:32:44,285] 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={__consumer_offsets-0=PartitionData(topicId=luVxKKl9Tf2TGcoaTSC0lA,
fetchOffset=3, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[2], lastFetchedEpoch=Optional[2])},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1140846877, epoch=4), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:44,285] WARN [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={topic-1=PartitionData(topicId=0CftS7C6T3GRKzHC-gaTFQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[1],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=1798269664, epoch=1), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
metaPropertiesEnsemble=MetaPropertiesEnsemble(metadataLogDir=Optional.empty,
dirs={/tmp/kafka-3842282715338511459: EMPTY})
[2023-11-28 22:32:44,534] WARN [QuorumController id=1000] Performing controller
activation. The metadata log appears to be empty. Appending 1 bootstrap
record(s) in metadata transaction at metadata.version 3.7-IV1 from bootstrap
source 'test harness'. Setting the ZK migration state to NONE since this is a
de-novo KRaft cluster. (org.apache.kafka.controller.QuorumController:108)
[2023-11-28 22:32:45,499] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@56ac7b1a
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 22:32:45,499] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@1e56d84
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 22:32:45,504] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@403f1279
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 22:32:46,513] WARN [ReplicaFetcher replicaId=2, leaderId=0,
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=695135585, epoch=4), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:46,513] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=282103315, epoch=3), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:46,646] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.1.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:46,748] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:47,049] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.1.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:47,147] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 2147483647 (localhost/127.0.1.1:45311)
could not be established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:47,513] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:47,513] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:47,514] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=2, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=695135585, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:47,514] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=282103315, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:47,551] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:47,651] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 2147483647 (localhost/127.0.0.1:45311)
could not be established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:48,153] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 2147483647 (localhost/127.0.1.1:45311)
could not be established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:48,455] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.1.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:48,514] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:48,514] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:48,514] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=282103315, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:48,515] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=2, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=695135585, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:48,655] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 2147483647 (localhost/127.0.0.1:45311)
could not be established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:49,361] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:49,515] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:49,515] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:49,516] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=2, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=695135585, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:49,516] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=282103315, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:49,660] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 2147483647 (localhost/127.0.1.1:45311)
could not be established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:50,264] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.1.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:50,516] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:50,516] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:50,516] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=2, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=695135585, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:50,516] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=282103315, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:50,664] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 2147483647 (localhost/127.0.0.1:45311)
could not be established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:51,274] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:51,517] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:51,517] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:51,517] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=282103315, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:51,518] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=2, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=695135585, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:51,669] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 2147483647 (localhost/127.0.1.1:45311)
could not be established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:52,276] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.1.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:52,518] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:52,518] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:52,518] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=2, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=695135585, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:52,519] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=282103315, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:52,579] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 2147483647 (localhost/127.0.0.1:45311)
could not be established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:53,180] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:53,470] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Connection to node 2147483647 (localhost/127.0.1.1:45311)
could not be established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:53,519] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:53,519] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Connection to node 0 (localhost/127.0.0.1:45311) could not be
established. Node may not be available.
(org.apache.kafka.clients.NetworkClient:814)
[2023-11-28 22:32:53,519] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=2, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=695135585, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:53,519] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=1, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0]),
topic-0=PartitionData(topicId=7A33RtBNRAGq8zZA1lJJOQ, fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, removed=,
replaced=, metadata=(sessionId=282103315, epoch=INITIAL), rackId=)
(kafka.server.ReplicaFetcherThread:72)
java.io.IOException: Connection to localhost:45311 (id: 0 rack: null) failed.
at
org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
at
kafka.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:108)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:54,084] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Close timed out with 1 pending requests to coordinator,
terminating client connections
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1123)
[2023-11-28 22:32:54,087] 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={__consumer_offsets-0=PartitionData(topicId=QpUQmO21Qba-R-yCKvgZ-g,
fetchOffset=4, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[1], lastFetchedEpoch=Optional[1])},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=359597478, epoch=18), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:32:54,416] WARN [NodeToControllerChannelManager id=1000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:667)
[2023-11-28 22:32:54,418] ERROR [QuorumController id=1000] Cancelling deferred
write event maybeFenceReplicas because the event queue is now closed.
(org.apache.kafka.controller.QuorumController:1297)
metaPropertiesEnsemble=MetaPropertiesEnsemble(metadataLogDir=Optional.empty,
dirs={/tmp/kafka-6888200266425032707: EMPTY})
[2023-11-28 22:32:54,443] WARN [QuorumController id=1000] Performing controller
activation. The metadata log appears to be empty. Appending 1 bootstrap
record(s) in metadata transaction at metadata.version 3.7-IV1 from bootstrap
source 'test harness'. Setting the ZK migration state to NONE since this is a
de-novo KRaft cluster. (org.apache.kafka.controller.QuorumController:108)
[2023-11-28 22:32:55,399] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@6c76155d
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 22:32:55,400] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@1937c8e
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 22:32:55,401] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@371497a
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at org.apache.kafka.queue.KafkaEventQueue$EventCont
...[truncated 2797622 chars]...
java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 22:44:22,187] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] Close timed out with 1 pending requests to coordinator,
terminating client connections
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1123)
[2023-11-28 22:44:22,191] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={tsomec-1=PartitionData(topicId=dKdOos2USI2FdR8JhU-KwQ,
fetchOffset=1000, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0])},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=152301008, epoch=9), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:44:22,191] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=2, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={tsomec-1=PartitionData(topicId=dKdOos2USI2FdR8JhU-KwQ,
fetchOffset=1000, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0])},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1438523841, epoch=9), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:44:22,191] WARN [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={tsomec-0=PartitionData(topicId=dKdOos2USI2FdR8JhU-KwQ,
fetchOffset=1000, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0])},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=450423079, epoch=23), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:44:22,191] WARN [ReplicaFetcher replicaId=0, leaderId=2,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=0, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={tsomec-0=PartitionData(topicId=dKdOos2USI2FdR8JhU-KwQ,
fetchOffset=1000, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0])},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1790334620, epoch=23), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:44:22,191] WARN [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=0, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData={__consumer_offsets-0=PartitionData(topicId=hNV3D7sjRmCoKFr8M5cIDA,
fetchOffset=4, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0])},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1882472249, epoch=44), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:44:22,191] 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={__consumer_offsets-0=PartitionData(topicId=hNV3D7sjRmCoKFr8M5cIDA,
fetchOffset=4, logStartOffset=0, maxBytes=1048576,
currentLeaderEpoch=Optional[0], lastFetchedEpoch=Optional[0])},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=941512031, epoch=44), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 22:44:22,542] WARN [NodeToControllerChannelManager id=1000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:667)
[2023-11-28 22:44:22,545] ERROR [QuorumController id=1000] Cancelling deferred
write event maybeFenceReplicas because the event queue is now closed.
(org.apache.kafka.controller.QuorumController:1297)
[2023-11-28 23:19:48,189] WARN maxCnxns is not configured, using default value
0. (org.apache.zookeeper.server.ServerCnxnFactory:309)
[2023-11-28 23:19:48,536] WARN [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition topic-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)
[2023-11-28 23:19:48,537] WARN [ReplicaFetcher replicaId=2, leaderId=1,
fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition topic-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)
[2023-11-28 23:19:48,538] WARN [ReplicaFetcher replicaId=0, leaderId=2,
fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition topic-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)
[2023-11-28 23:19:48,538] WARN [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Received UNKNOWN_TOPIC_ID from the leader for partition topic-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)
[2023-11-28 23:19:50,559] WARN [Producer clientId=ConsumerTestProducer]
delivery.timeout.ms should be equal to or larger than linger.ms +
request.timeout.ms. Setting it to 2147483647.
(org.apache.kafka.clients.producer.KafkaProducer:560)
[2023-11-28 23:19:51,807] WARN [ReplicaFetcher replicaId=0, leaderId=2,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=0, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=958284730, epoch=5), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:51,807] WARN [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=121456605, epoch=5), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:51,807] WARN [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=0, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1490435564, epoch=5), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:51,808] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1567850327, epoch=6), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:51,808] 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=1555119328, epoch=5), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:51,808] WARN [ReplicaFetcher replicaId=2, leaderId=0,
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=351277526, epoch=6), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
metaPropertiesEnsemble=MetaPropertiesEnsemble(metadataLogDir=Optional.empty,
dirs={/tmp/kafka-16453547074389008049: EMPTY})
[2023-11-28 23:19:52,093] WARN [QuorumController id=1000] Performing controller
activation. The metadata log appears to be empty. Appending 1 bootstrap
record(s) in metadata transaction at metadata.version 3.7-IV1 from bootstrap
source 'test harness'. Setting the ZK migration state to NONE since this is a
de-novo KRaft cluster. (org.apache.kafka.controller.QuorumController:108)
[2023-11-28 23:19:53,080] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@502f739a
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:19:53,081] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@503838ca
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:19:53,081] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@1439aa21
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:19:53,825] WARN [Producer clientId=ConsumerTestProducer]
delivery.timeout.ms should be equal to or larger than linger.ms +
request.timeout.ms. Setting it to 2147483647.
(org.apache.kafka.clients.producer.KafkaProducer:560)
[2023-11-28 23:19:54,853] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=145239054, epoch=5), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:54,853] 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=1189011807, epoch=5), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:54,853] WARN [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=0, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1943161650, epoch=5), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:54,854] WARN [ReplicaFetcher replicaId=2, leaderId=0,
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=428781265, epoch=5), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:55,017] WARN [NodeToControllerChannelManager id=1000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:667)
[2023-11-28 23:19:55,019] ERROR [QuorumController id=1000] Cancelling deferred
write event maybeFenceReplicas because the event queue is now closed.
(org.apache.kafka.controller.QuorumController:1297)
metaPropertiesEnsemble=MetaPropertiesEnsemble(metadataLogDir=Optional.empty,
dirs={/tmp/kafka-4036458965452388226: EMPTY})
[2023-11-28 23:19:55,050] WARN [QuorumController id=1000] Performing controller
activation. The metadata log appears to be empty. Appending 1 bootstrap
record(s) in metadata transaction at metadata.version 3.7-IV1 from bootstrap
source 'test harness'. Setting the ZK migration state to NONE since this is a
de-novo KRaft cluster. (org.apache.kafka.controller.QuorumController:108)
[2023-11-28 23:19:56,031] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@6b05363a
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:19:56,033] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@504c619e
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:19:56,033] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@74796fb4
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:19:56,871] WARN [Producer clientId=ConsumerTestProducer]
delivery.timeout.ms should be equal to or larger than linger.ms +
request.timeout.ms. Setting it to 2147483647.
(org.apache.kafka.clients.producer.KafkaProducer:560)
[2023-11-28 23:19:57,912] WARN [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=513660765, epoch=5), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:57,913] WARN [ReplicaFetcher replicaId=0, leaderId=2,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=0, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=462250570, epoch=5), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:57,913] 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=49478967, epoch=5), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:57,913] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1136363756, epoch=5), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:57,913] WARN [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=0, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1394899890, epoch=5), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:57,914] WARN [ReplicaFetcher replicaId=2, leaderId=0,
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=820589906, epoch=5), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:19:58,216] WARN [NodeToControllerChannelManager id=1000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:667)
[2023-11-28 23:19:58,218] ERROR [QuorumController id=1000] Cancelling deferred
write event maybeFenceReplicas because the event queue is now closed.
(org.apache.kafka.controller.QuorumController:1297)
metaPropertiesEnsemble=MetaPropertiesEnsemble(metadataLogDir=Optional.empty,
dirs={/tmp/kafka-2823784908060096373: EMPTY})
[2023-11-28 23:19:58,244] WARN [QuorumController id=1000] Performing controller
activation. The metadata log appears to be empty. Appending 1 bootstrap
record(s) in metadata transaction at metadata.version 3.7-IV1 from bootstrap
source 'test harness'. Setting the ZK migration state to NONE since this is a
de-novo KRaft cluster. (org.apache.kafka.controller.QuorumController:108)
[2023-11-28 23:19:59,395] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@4726f78d
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:19:59,396] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@66f23734
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:19:59,396] ERROR Unexpected error handling
org.apache.kafka.server.AssignmentsManager$DispatchEvent@423b55e3
(org.apache.kafka.server.AssignmentsManager:117)
java.lang.IllegalStateException: Cannot enqueue a request if the request thread
is not running
at
kafka.server.NodeToControllerRequestThread.enqueue(NodeToControllerChannelManager.scala:309)
at
kafka.server.NodeToControllerChannelManagerImpl.sendRequest(NodeToControllerChannelManager.scala:239)
at
org.apache.kafka.server.AssignmentsManager$DispatchEvent.run(AssignmentsManager.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:20:05,547] WARN [Producer clientId=ConsumerTestProducer]
delivery.timeout.ms should be equal to or larger than linger.ms +
request.timeout.ms. Setting it to 2147483647.
(org.apache.kafka.clients.producer.KafkaProducer:560)
[2023-11-28 23:20:09,432] WARN [Consumer clientId=ConsumerTestConsumer,
groupId=my-test] The fetch buffer was already closed
(org.apache.kafka.clients.consumer.internals.FetchBuffer:263)
[2023-11-28 23:20:09,434] WARN [ReplicaFetcher replicaId=0, leaderId=1,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=0, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=365803585, epoch=14), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:20:09,434] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={},
isolationLevel=READ_UNCOMMITTED, removed=, replaced=,
metadata=(sessionId=1978360363, epoch=14), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:20:09,434] WARN [ReplicaFetcher replicaId=2, leaderId=0,
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=2059879385, epoch=14), rackId=)
(kafka.server.ReplicaFetcherThread: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.server.BrokerBlockingSender.sendRequest(BrokerBlockingSender.scala:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:20:09,434] 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=2110384598, epoch=14), 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:113)
at
kafka.server.RemoteLeaderEndPoint.fetch(RemoteLeaderEndPoint.scala:79)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:131)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:130)
at scala.Option.foreach(Option.scala:437)
at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:130)
at
kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at
kafka.server.ReplicaFetcherThread.doWork(ReplicaFetcherThread.scala:98)
at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-11-28 23:20:09,617] WARN [NodeToControllerChannelManager id=1000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:667)
[2023-11-28 23:20:09,619] ERROR [QuorumController id=1000] Cancelling deferred
write event maybeFenceReplicas because the event queue is now closed.
(org.apache.kafka.controller.QuorumController:1297)```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
