You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Josep Prat (Jira)" <ji...@apache.org> on 2023/06/19 07:33:00 UTC
[jira] [Commented] (KAFKA-15103) Flaky test KRaftClusterTest.testCreateClusterAndPerformReassignment
[ https://issues.apache.org/jira/browse/KAFKA-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734030#comment-17734030 ]
Josep Prat commented on KAFKA-15103:
------------------------------------
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)