[ https://issues.apache.org/jira/browse/KAFKA-15103 ]
Josep Prat deleted comment on KAFKA-15103:
------------------------------------
was (Author: jlprat):
h3. Standard Output
{code:java}
[2023-06-16 18:39:33,807] WARN [QuorumController id=3001] Renouncing the
leadership due to a metadata log event. We were the leader at epoch 1, but in
the new epoch 2, the leader is (none). Reverting to last committed offset -1.
(org.apache.kafka.controller.QuorumController:1072) [2023-06-16 18:39:33,816]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:39:33,869]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:39:35,082]
WARN [QuorumController id=3002] Renouncing the leadership due to a metadata log
event. We were the leader at epoch 2, but in the new epoch 3, the leader is
(none). Reverting to last committed offset 6.
(org.apache.kafka.controller.QuorumController:1072) [2023-06-16 18:39:35,487]
ERROR [QuorumController id=3002] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3000. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:39:36,107] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:38565) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:39:36,199] WARN [QuorumController id=3000] Renouncing the leadership due to
a metadata log event. We were the leader at epoch 3, but in the new epoch 4,
the leader is (none). Reverting to last committed offset 9.
(org.apache.kafka.controller.QuorumController:1072) [2023-06-16 18:39:36,223]
WARN [RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565)
could not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:36,409] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:36,841] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:37,461] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:38,021] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:38,605] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:39,132] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:39,710] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:40,231] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:40,817] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:38565) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:39:41,117] WARN
[RaftManager id=3001] Graceful shutdown timed out after 5000ms
(org.apache.kafka.raft.KafkaRaftClient:2444) [2023-06-16 18:39:41,119] ERROR
[kafka-3001-raft-io-thread]: Graceful shutdown of RaftClient failed
(kafka.raft.KafkaRaftManager$RaftIoThread:76)
java.util.concurrent.TimeoutException: Timeout expired before graceful shutdown
completed at
org.apache.kafka.raft.KafkaRaftClient$GracefulShutdown.failWithTimeout(KafkaRaftClient.java:2445)
at
org.apache.kafka.raft.KafkaRaftClient.maybeCompleteShutdown(KafkaRaftClient.java:2191)
at org.apache.kafka.raft.KafkaRaftClient.poll(KafkaRaftClient.java:2256) at
kafka.raft.KafkaRaftManager$RaftIoThread.doWork(RaftManager.scala:64) at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127)
[2023-06-16 18:39:41,150] ERROR [QuorumController id=3001] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:39:41,290] ERROR Encountered fatalFaultHandler fault: caught
exception (org.apache.kafka.server.fault.MockFaultHandler:44)
java.lang.IllegalStateException: test authorizer exception at
kafka.server.BadAuthorizer.start(KRaftClusterTest.scala:1172) at
kafka.server.ControllerServer.startup(ControllerServer.scala:167) at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at
java.util.concurrent.FutureTask.run(FutureTask.java:266) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750) [2023-06-16 18:39:41,291] ERROR
Encountered fatalFaultHandler fault: caught exception
(org.apache.kafka.server.fault.MockFaultHandler:44)
java.lang.IllegalStateException: test authorizer exception at
kafka.server.BadAuthorizer.start(KRaftClusterTest.scala:1172) at
kafka.server.ControllerServer.startup(ControllerServer.scala:167) at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at
java.util.concurrent.FutureTask.run(FutureTask.java:266) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750) [2023-06-16 18:39:41,292] ERROR
Encountered fatalFaultHandler fault: caught exception
(org.apache.kafka.server.fault.MockFaultHandler:44)
java.lang.IllegalStateException: test authorizer exception at
kafka.server.BadAuthorizer.start(KRaftClusterTest.scala:1172) at
kafka.server.ControllerServer.startup(ControllerServer.scala:167) at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at
java.util.concurrent.FutureTask.run(FutureTask.java:266) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750) [2023-06-16 18:39:44,398] WARN Unable
to describeConfigs([ConfigResource(type=BROKER, name='')])
(kafka.server.KRaftClusterTest:600) org.opentest4j.AssertionFailedError:
expected: <{log.roll.ms=1234567, max.connections.per.ip=60}> but was: <{}> at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:182) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:177) at
org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1142) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$2(KRaftClusterTest.scala:595)
at scala.collection.immutable.Map$Map1.foreach(Map.scala:193) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$1(KRaftClusterTest.scala:580)
at kafka.server.KRaftClusterTest.validateConfigs(KRaftClusterTest.scala:576)
at
kafka.server.KRaftClusterTest.testIncrementalAlterConfigs(KRaftClusterTest.scala:625)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:45)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.util.ArrayList.forEach(ArrayList.java:1259) at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.util.ArrayList.forEach(ArrayList.java:1259) at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
at
org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:110)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:90)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:85)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.stop(Unknown Source) at
org.gradle.api.internal.tasks.testing.worker.TestWorker$3.run(TestWorker.java:193)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
at
org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:113)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:65)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
[2023-06-16 18:39:44,402] WARN Unable to
describeConfigs([ConfigResource(type=BROKER, name='')])
(kafka.server.KRaftClusterTest:600) org.opentest4j.AssertionFailedError:
expected: <{log.roll.ms=1234567, max.connections.per.ip=60}> but was: <{}> at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:182) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:177) at
org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1142) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$2(KRaftClusterTest.scala:595)
at scala.collection.immutable.Map$Map1.foreach(Map.scala:193) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$1(KRaftClusterTest.scala:580)
at kafka.server.KRaftClusterTest.validateConfigs(KRaftClusterTest.scala:576)
at
kafka.server.KRaftClusterTest.testIncrementalAlterConfigs(KRaftClusterTest.scala:625)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:45)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.util.ArrayList.forEach(ArrayList.java:1259) at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.util.ArrayList.forEach(ArrayList.java:1259) at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
at
org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:110)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:90)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:85)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.stop(Unknown Source) at
org.gradle.api.internal.tasks.testing.worker.TestWorker$3.run(TestWorker.java:193)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
at
org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:113)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:65)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
[2023-06-16 18:39:44,406] WARN Unable to
describeConfigs([ConfigResource(type=BROKER, name='')])
(kafka.server.KRaftClusterTest:600) org.opentest4j.AssertionFailedError:
expected: <{log.roll.ms=1234567, max.connections.per.ip=60}> but was: <{}> at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:182) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:177) at
org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1142) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$2(KRaftClusterTest.scala:595)
at scala.collection.immutable.Map$Map1.foreach(Map.scala:193) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$1(KRaftClusterTest.scala:580)
at kafka.server.KRaftClusterTest.validateConfigs(KRaftClusterTest.scala:576)
at
kafka.server.KRaftClusterTest.testIncrementalAlterConfigs(KRaftClusterTest.scala:625)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:45)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.util.ArrayList.forEach(ArrayList.java:1259) at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.util.ArrayList.forEach(ArrayList.java:1259) at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
at
org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:110)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:90)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:85)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.stop(Unknown Source) at
org.gradle.api.internal.tasks.testing.worker.TestWorker$3.run(TestWorker.java:193)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
at
org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:113)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:65)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
[2023-06-16 18:39:44,412] WARN Unable to
describeConfigs([ConfigResource(type=BROKER, name='')])
(kafka.server.KRaftClusterTest:600) org.opentest4j.AssertionFailedError:
expected: <{log.roll.ms=1234567, max.connections.per.ip=60}> but was: <{}> at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:182) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:177) at
org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1142) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$2(KRaftClusterTest.scala:595)
at scala.collection.immutable.Map$Map1.foreach(Map.scala:193) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$1(KRaftClusterTest.scala:580)
at kafka.server.KRaftClusterTest.validateConfigs(KRaftClusterTest.scala:576)
at
kafka.server.KRaftClusterTest.testIncrementalAlterConfigs(KRaftClusterTest.scala:625)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:45)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.util.ArrayList.forEach(ArrayList.java:1259) at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.util.ArrayList.forEach(ArrayList.java:1259) at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at
org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at
org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
at
org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:110)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:90)
at
org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:85)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.stop(Unknown Source) at
org.gradle.api.internal.tasks.testing.worker.TestWorker$3.run(TestWorker.java:193)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
at
org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:113)
at
org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:65)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
at
worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
[2023-06-16 18:39:44,422] WARN Unable to
describeConfigs([ConfigResource(type=BROKER, name='')])
(kafka.server.KRaftClusterTest:600) org.opentest4j.AssertionFailedError:
expected: <{log.roll.ms=1234567, max.connections.per.ip=60}> but was: <{}> at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:182) at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:177) at
org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1142) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$2(KRaftClusterTest.scala:595)
at scala.collection.immutable.Map$Map1.foreach(Map.scala:193) at
kafka.server.KRaftClusterTest.$anonfun$validateConfigs$1(KRaftClusterTest.scala:580)
at kafka.server.KRaftClusterTest.validateConfigs(KRaftClusterTest.scala:576)
at
kafka.server.KRaftClusterTest.testIncrementalAlterConfigs(KRaftClusterTest.scala:625)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498) at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at
org.junit.jupiter.engine.extension.SameThreadTimeoutInvocation.proceed(SameThreadTimeoutInvocation.java:45)
at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at org.junit.jupiter.engine.execution.InvocationInte ...[truncated 666493
chars]... kafka.controller.QuorumController:467) [2023-06-16 18:40:49,133]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,134] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,134] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,135]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,135] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,136] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,185]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,185] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,186] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,186]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,187] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,187] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,236]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,237] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,238] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,238]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,238] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,239] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,288]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,289] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,290] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,290]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,291] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,291] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,340]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,341] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,342] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,342]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,342] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,343] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,392]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,393] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,393] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:49,394]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: No controller appears to
be active. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:40:49,394] ERROR [QuorumController id=3001] processBrokerHeartbeat: unable
to start processing because of NotControllerException. Reason: No controller
appears to be active. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:49,395] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: No
controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:57,861]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:57,861] ERROR [QuorumController id=3001]
processBrokerHeartbeat: unable to start processing because of
NotControllerException. Reason: The active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:57,861]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:57,862] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: The
active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:57,862]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:57,863] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: The
active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:57,913]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:57,913] ERROR [QuorumController id=3001]
processBrokerHeartbeat: unable to start processing because of
NotControllerException. Reason: The active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:57,914]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:57,914] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: The
active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:57,914]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:57,915] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: The
active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:57,965]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:57,965] ERROR [QuorumController id=3001]
processBrokerHeartbeat: unable to start processing because of
NotControllerException. Reason: The active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:57,966]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:57,966] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: The
active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:57,966]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:57,967] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: The
active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:58,017]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:58,018] ERROR [QuorumController id=3001]
processBrokerHeartbeat: unable to start processing because of
NotControllerException. Reason: The active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:58,018]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:58,018] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: The
active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:58,018]
ERROR [QuorumController id=3001] processBrokerHeartbeat: unable to start
processing because of NotControllerException. Reason: The active controller
appears to be node 3001. (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:40:58,019] ERROR [QuorumController id=3001] alterPartition:
unable to start processing because of NotControllerException. Reason: The
active controller appears to be node 3001.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:40:58,325]
WARN [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Partition foo-2
marked as failed (kafka.server.ReplicaFetcherThread:70) [2023-06-16
18:40:58,465] WARN [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0]
Partition foo-1 marked as failed (kafka.server.ReplicaFetcherThread:70)
[2023-06-16 18:41:01,774] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:01,774] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:01,876] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:01,897] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:02,093] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:02,093] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:02,515] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:02,536] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:02,970] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:03,098] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:03,546] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:03,655] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:04,012] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:04,216] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:04,606] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:04,648] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:05,199] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:05,240] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:05,704] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:05,825] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:06,246] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:44333) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:06,267] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:41697) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:06,618] WARN [RaftManager id=3001] Graceful shutdown timed out after
5000ms (org.apache.kafka.raft.KafkaRaftClient:2444) [2023-06-16 18:41:06,619]
ERROR [kafka-3001-raft-io-thread]: Graceful shutdown of RaftClient failed
(kafka.raft.KafkaRaftManager$RaftIoThread:76)
java.util.concurrent.TimeoutException: Timeout expired before graceful shutdown
completed at
org.apache.kafka.raft.KafkaRaftClient$GracefulShutdown.failWithTimeout(KafkaRaftClient.java:2445)
at
org.apache.kafka.raft.KafkaRaftClient.maybeCompleteShutdown(KafkaRaftClient.java:2191)
at org.apache.kafka.raft.KafkaRaftClient.poll(KafkaRaftClient.java:2256) at
kafka.raft.KafkaRaftManager$RaftIoThread.doWork(RaftManager.scala:64) at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127)
[2023-06-16 18:41:06,719] ERROR [QuorumController id=3001] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:41:06,720] ERROR [QuorumController id=3001]
maybeBalancePartitionLeaders: unable to start processing because of
RejectedExecutionException. Reason: The event queue is shutting down
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:08,302]
ERROR [QuorumController id=3000] writeNoOpRecord: unable to start processing
because of RejectedExecutionException. Reason: The event queue is shutting down
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,259]
WARN [QuorumController id=3001] Renouncing the leadership due to a metadata log
event. We were the leader at epoch 1, but in the new epoch 2, the leader is
(none). Reverting to last committed offset -1.
(org.apache.kafka.controller.QuorumController:1072) [2023-06-16 18:41:11,354]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,354]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,356]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,357]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,407]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,407]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,409]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,409]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,460]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,460]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,460]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:11,461]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:13,871]
ERROR [QuorumController id=3001] unregisterBroker: unable to start processing
because of NotControllerException. Reason: The active controller appears to be
node 3000. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:41:15,003] WARN [QuorumController id=3000] Renouncing the leadership due to
a metadata log event. We were the leader at epoch 2, but in the new epoch 3,
the leader is (none). Reverting to last committed offset 22.
(org.apache.kafka.controller.QuorumController:1072) [2023-06-16 18:41:19,966]
WARN [RaftManager id=3001] Graceful shutdown timed out after 5000ms
(org.apache.kafka.raft.KafkaRaftClient:2444) [2023-06-16 18:41:19,966] ERROR
[kafka-3001-raft-io-thread]: Graceful shutdown of RaftClient failed
(kafka.raft.KafkaRaftManager$RaftIoThread:76)
java.util.concurrent.TimeoutException: Timeout expired before graceful shutdown
completed at
org.apache.kafka.raft.KafkaRaftClient$GracefulShutdown.failWithTimeout(KafkaRaftClient.java:2445)
at
org.apache.kafka.raft.KafkaRaftClient.maybeCompleteShutdown(KafkaRaftClient.java:2191)
at org.apache.kafka.raft.KafkaRaftClient.poll(KafkaRaftClient.java:2256) at
kafka.raft.KafkaRaftManager$RaftIoThread.doWork(RaftManager.scala:64) at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127)
[2023-06-16 18:41:20,025] ERROR [QuorumController id=3001] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:41:23,288] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:23,288] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:23,399] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:23,399] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:23,594] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:23,615] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:23,971] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:23,971] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:24,416] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:24,505] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:25,027] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:25,048] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:25,510] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:25,587] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:26,116] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:26,158] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:26,564] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:26,670] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:27,035] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:27,105] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:27,510] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:27,632] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:27,978] WARN [RaftManager id=3001] Connection to node 3002
(localhost/127.0.0.1:35201) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:28,172] WARN [RaftManager id=3001] Connection to node 3000
(localhost/127.0.0.1:41427) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:28,218] WARN [RaftManager id=3001] Graceful shutdown timed out after
5000ms (org.apache.kafka.raft.KafkaRaftClient:2444) [2023-06-16 18:41:28,219]
ERROR [kafka-3001-raft-io-thread]: Graceful shutdown of RaftClient failed
(kafka.raft.KafkaRaftManager$RaftIoThread:76)
java.util.concurrent.TimeoutException: Timeout expired before graceful shutdown
completed at
org.apache.kafka.raft.KafkaRaftClient$GracefulShutdown.failWithTimeout(KafkaRaftClient.java:2445)
at
org.apache.kafka.raft.KafkaRaftClient.maybeCompleteShutdown(KafkaRaftClient.java:2191)
at org.apache.kafka.raft.KafkaRaftClient.poll(KafkaRaftClient.java:2256) at
kafka.raft.KafkaRaftManager$RaftIoThread.doWork(RaftManager.scala:64) at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127)
[2023-06-16 18:41:28,262] ERROR [QuorumController id=3001] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:41:29,656] ERROR [QuorumController id=3000] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:41:33,379] WARN [ReplicaFetcher replicaId=0, leaderId=2,
fetcherId=0] Partition test-topic-2-1 marked as failed
(kafka.server.ReplicaFetcherThread:70) [2023-06-16 18:41:33,379] WARN
[ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Partition test-topic-2-1
marked as failed (kafka.server.ReplicaFetcherThread:70) [2023-06-16
18:41:34,372] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:34,372] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:34,486] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:34,486] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:34,713] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:34,734] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:35,080] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:35,204] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:35,538] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:35,803] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:36,024] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:36,378] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:36,496] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:36,824] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:37,024] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:37,296] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:37,545] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:37,910] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:38,085] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:38,428] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:38,660] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:39,039] WARN [RaftManager id=3000] Connection to node 3001
(localhost/127.0.0.1:40361) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:39,265] WARN [RaftManager id=3000] Connection to node 3002
(localhost/127.0.0.1:41897) could not be established. Broker may not be
available. (org.apache.kafka.clients.NetworkClient:814) [2023-06-16
18:41:39,317] WARN [RaftManager id=3000] Graceful shutdown timed out after
5000ms (org.apache.kafka.raft.KafkaRaftClient:2444) [2023-06-16 18:41:39,318]
ERROR [kafka-3000-raft-io-thread]: Graceful shutdown of RaftClient failed
(kafka.raft.KafkaRaftManager$RaftIoThread:76)
java.util.concurrent.TimeoutException: Timeout expired before graceful shutdown
completed at
org.apache.kafka.raft.KafkaRaftClient$GracefulShutdown.failWithTimeout(KafkaRaftClient.java:2445)
at
org.apache.kafka.raft.KafkaRaftClient.maybeCompleteShutdown(KafkaRaftClient.java:2191)
at org.apache.kafka.raft.KafkaRaftClient.poll(KafkaRaftClient.java:2256) at
kafka.raft.KafkaRaftManager$RaftIoThread.doWork(RaftManager.scala:64) at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127)
[2023-06-16 18:41:39,361] ERROR [QuorumController id=3000] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:41:39,362] ERROR [QuorumController id=3000]
maybeBalancePartitionLeaders: unable to start processing because of
RejectedExecutionException. Reason: The event queue is shutting down
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:40,446]
ERROR [QuorumController id=3000] writeNoOpRecord: unable to start processing
because of RejectedExecutionException. Reason: The event queue is shutting down
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:45,460]
WARN [QuorumController id=3000] Renouncing the leadership due to a metadata log
event. We were the leader at epoch 1, but in the new epoch 2, the leader is
(none). Reverting to last committed offset 15.
(org.apache.kafka.controller.QuorumController:1072) [2023-06-16 18:41:50,440]
WARN [RaftManager id=3001] Graceful shutdown timed out after 5000ms
(org.apache.kafka.raft.KafkaRaftClient:2444) [2023-06-16 18:41:50,440] ERROR
[kafka-3001-raft-io-thread]: Graceful shutdown of RaftClient failed
(kafka.raft.KafkaRaftManager$RaftIoThread:76)
java.util.concurrent.TimeoutException: Timeout expired before graceful shutdown
completed at
org.apache.kafka.raft.KafkaRaftClient$GracefulShutdown.failWithTimeout(KafkaRaftClient.java:2445)
at
org.apache.kafka.raft.KafkaRaftClient.maybeCompleteShutdown(KafkaRaftClient.java:2191)
at org.apache.kafka.raft.KafkaRaftClient.poll(KafkaRaftClient.java:2256) at
kafka.raft.KafkaRaftManager$RaftIoThread.doWork(RaftManager.scala:64) at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127)
[2023-06-16 18:41:50,476] ERROR [QuorumController id=3001] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:41:52,164] WARN [QuorumController id=3001] Renouncing the
leadership due to a metadata log event. We were the leader at epoch 1, but in
the new epoch 2, the leader is (none). Reverting to last committed offset -1.
(org.apache.kafka.controller.QuorumController:1072) [2023-06-16 18:41:52,189]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:52,191]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:52,219]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:52,241]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:52,243]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:52,271]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:52,293]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:52,295]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:52,323]
ERROR [QuorumController id=3001] registerBroker: unable to start processing
because of NotControllerException. Reason: No controller appears to be active.
(org.apache.kafka.controller.QuorumController:467) [2023-06-16 18:41:54,883]
ERROR [QuorumController id=3001] createTopics: unable to start processing
because of NotControllerException. Reason: The active controller appears to be
node 3000. (org.apache.kafka.controller.QuorumController:467) [2023-06-16
18:41:56,961] WARN [QuorumController id=3000] Renouncing the leadership due to
a metadata log event. We were the leader at epoch 2, but in the new epoch 3,
the leader is (none). Reverting to last committed offset 22.
(org.apache.kafka.controller.QuorumController:1072) [2023-06-16 18:42:01,904]
WARN [RaftManager id=3001] Graceful shutdown timed out after 5000ms
(org.apache.kafka.raft.KafkaRaftClient:2444) [2023-06-16 18:42:01,905] ERROR
[kafka-3001-raft-io-thread]: Graceful shutdown of RaftClient failed
(kafka.raft.KafkaRaftManager$RaftIoThread:76)
java.util.concurrent.TimeoutException: Timeout expired before graceful shutdown
completed at
org.apache.kafka.raft.KafkaRaftClient$GracefulShutdown.failWithTimeout(KafkaRaftClient.java:2445)
at
org.apache.kafka.raft.KafkaRaftClient.maybeCompleteShutdown(KafkaRaftClient.java:2191)
at org.apache.kafka.raft.KafkaRaftClient.poll(KafkaRaftClient.java:2256) at
kafka.raft.KafkaRaftManager$RaftIoThread.doWork(RaftManager.scala:64) at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127)
[2023-06-16 18:42:01,946] ERROR [QuorumController id=3001] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:42:03,050] ERROR [QuorumController id=3000] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:56:16,953] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Partition foo-0 marked as failed
(kafka.server.ReplicaFetcherThread:70) [2023-06-16 18:56:16,959] WARN
[ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Partition foo-3 marked as
failed (kafka.server.ReplicaFetcherThread:70) [2023-06-16 18:56:16,957] WARN
[ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Partition foo-1 marked as
failed (kafka.server.ReplicaFetcherThread:70) [2023-06-16 18:56:19,144] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:19,145] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:19,253] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:19,273] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:19,471] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:19,514] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:19,834] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:19,942] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:20,438] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:20,517] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:20,952] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:20,995] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:21,489] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:21,580] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:21,914] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:22,157] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:22,418] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:22,630] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:23,034] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:23,135] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:23,559] WARN
[RaftManager id=3001] Connection to node 3000 (localhost/127.0.0.1:37503) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:23,671] WARN
[RaftManager id=3001] Connection to node 3002 (localhost/127.0.0.1:46659) could
not be established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient:814) [2023-06-16 18:56:23,980] WARN
[RaftManager id=3001] Graceful shutdown timed out after 5000ms
(org.apache.kafka.raft.KafkaRaftClient:2444) [2023-06-16 18:56:23,983] ERROR
[kafka-3001-raft-io-thread]: Graceful shutdown of RaftClient failed
(kafka.raft.KafkaRaftManager$RaftIoThread:76)
java.util.concurrent.TimeoutException: Timeout expired before graceful shutdown
completed at
org.apache.kafka.raft.KafkaRaftClient$GracefulShutdown.failWithTimeout(KafkaRaftClient.java:2445)
at
org.apache.kafka.raft.KafkaRaftClient.maybeCompleteShutdown(KafkaRaftClient.java:2191)
at org.apache.kafka.raft.KafkaRaftClient.poll(KafkaRaftClient.java:2256) at
kafka.raft.KafkaRaftManager$RaftIoThread.doWork(RaftManager.scala:64) at
org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127)
[2023-06-16 18:56:24,025] ERROR [QuorumController id=3001] writeNoOpRecord:
unable to start processing because of RejectedExecutionException. Reason: The
event queue is shutting down (org.apache.kafka.controller.QuorumController:467)
[2023-06-16 18:56:24,026] ERROR [QuorumController id=3001]
maybeBalancePartitionLeaders: unable to start processing because of
RejectedExecutionException. Reason: The event queue is shutting down
(org.apache.kafka.controller.QuorumController:467) {code}
> Flaky test KRaftClusterTest.testCreateClusterAndPerformReassignment
> -------------------------------------------------------------------
>
> Key: KAFKA-15103
> URL: https://issues.apache.org/jira/browse/KAFKA-15103
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Josep Prat
> Priority: Major
> Labels: flaky-test
> Fix For: 3.5.0
>
>
> {{The test
> kafka.server.KRaftClusterTest.testCreateClusterAndPerformReassignment() is
> failing:
> [https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13865/2/testReport/junit/kafka.server/KRaftClusterTest/Build___JDK_8_and_Scala_2_12___testCreateClusterAndPerformReassignment__/]}}
> h3. Error Message
> {code:java}
> org.opentest4j.AssertionFailedError: Timed out waiting for replica
> assignments for topic foo. Wanted: List(List(2, 1, 0), List(0, 1, 2), List(2,
> 3), List(3, 2, 0, 1)). Got: ArrayBuffer(ArrayBuffer(2, 1, 0), ArrayBuffer(0,
> 1, 2, 3), ArrayBuffer(2, 3), ArrayBuffer(3, 2, 0, 1)){code}
> h3. Stacktrace
> {code:java}
> org.opentest4j.AssertionFailedError: Timed out waiting for replica
> assignments for topic foo. Wanted: List(List(2, 1, 0), List(0, 1, 2), List(2,
> 3), List(3, 2, 0, 1)). Got: ArrayBuffer(ArrayBuffer(2, 1, 0), ArrayBuffer(0,
> 1, 2, 3), ArrayBuffer(2, 3), ArrayBuffer(3, 2, 0, 1)) at
> org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:38) at
> org.junit.jupiter.api.Assertions.fail(Assertions.java:135) at
> kafka.server.KRaftClusterTest.testCreateClusterAndPerformReassignment(KRaftClusterTest.scala:479)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
