gistfile1.txt

[2023-12-06 05:14:50,514] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309)
[2023-12-06 05:15:08,116] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:10,365] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:12,464] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:14,671] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:16,763] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:20,127] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:23,013] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:25,169] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:28,867] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:36,671] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:40,827] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:45,117] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:48,263] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:15:53,376] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:16:00,317] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:16:03,562] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:16:14,572] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:16:24,469] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:16:29,466] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:16:31,817] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:16:33,565] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:16:35,469] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45709 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:18:11,413] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:18:13,415] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:18:16,059] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:18:23,067] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:18:29,920] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:18:33,868] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 05:18:38,065] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 06:51:51,337] WARN Client session timed out, have not heard from server in 5589572ms for session id 0x100829549c40001 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 06:51:51,340] WARN Session 0x100829549c40001 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 5589572ms for session id 0x100829549c40001
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 06:51:51,335] WARN Client session timed out, have not heard from server in 5592665ms for session id 0x100829549c40002 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 06:51:51,341] WARN Session 0x100829549c40002 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 5592665ms for session id 0x100829549c40002
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 06:51:51,335] WARN Client session timed out, have not heard from server in 5589014ms for session id 0x100829549c40005 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 06:51:51,341] WARN Session 0x100829549c40005 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 5589014ms for session id 0x100829549c40005
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 06:51:51,341] WARN Client session timed out, have not heard from server in 5593430ms for session id 0x100829549c40003 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 06:51:51,341] WARN Session 0x100829549c40003 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 5593430ms for session id 0x100829549c40003
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 06:51:51,334] WARN Client session timed out, have not heard from server in 5590124ms for session id 0x100829549c40004 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 06:51:51,341] WARN Session 0x100829549c40004 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 5590124ms for session id 0x100829549c40004
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 06:51:51,334] WARN Client session timed out, have not heard from server in 5591519ms for session id 0x100829549c40000 (org.apache.zookeeper.ClientCnxn:1256)
[2023-12-06 06:51:51,341] WARN Session 0x100829549c40000 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 5591519ms for session id 0x100829549c40000
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257)
[2023-12-06 06:51:51,733] ERROR [KafkaServer id=2] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer:159)
kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
	at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:258)
	at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:116)
	at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:2266)
	at kafka.security.authorizer.AclAuthorizer.configure(AclAuthorizer.scala:211)
	at kafka.server.KafkaServer.$anonfun$startup$19(KafkaServer.scala:524)
	at kafka.server.KafkaServer.$anonfun$startup$19$adapted(KafkaServer.scala:524)
	at scala.Option.foreach(Option.scala:437)
	at kafka.server.KafkaServer.startup(KafkaServer.scala:524)
	at kafka.integration.KafkaServerTestHarness.$anonfun$createBrokers$1(KafkaServerTestHarness.scala:356)
	at kafka.integration.KafkaServerTestHarness.$anonfun$createBrokers$1$adapted(KafkaServerTestHarness.scala:352)
	at scala.collection.immutable.Vector.foreach(Vector.scala:2124)
	at kafka.integration.KafkaServerTestHarness.createBrokers(KafkaServerTestHarness.scala:352)
	at kafka.integration.KafkaServerTestHarness.setUp(KafkaServerTestHarness.scala:121)
	at kafka.api.IntegrationTestHarness.doSetup(IntegrationTestHarness.scala:134)
	at kafka.api.IntegrationTestHarness.setUp(IntegrationTestHarness.scala:114)
	at kafka.api.EndToEndAuthorizationTest.setUp(EndToEndAuthorizationTest.scala:166)
	at kafka.api.SaslEndToEndAuthorizationTest.setUp(SaslEndToEndAuthorizationTest.scala:52)
	at jdk.internal.reflect.GeneratedMethodAccessor108.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728)
	at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
	at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptLifecycleMethod(TimeoutExtension.java:128)
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptBeforeEachMethod(TimeoutExtension.java:78)
	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.ClassBasedTestDescriptor.invokeMethodInExtensionContext(ClassBasedTestDescriptor.java:521)
	at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$synthesizeBeforeEachMethodAdapter$23(ClassBasedTestDescriptor.java:506)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeEachMethods$3(TestMethodTestDescriptor.java:175)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeBeforeMethodsOrCallbacksUntilExceptionOccurs$6(TestMethodTestDescriptor.java:203)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeMethodsOrCallbacksUntilExceptionOccurs(TestMethodTestDescriptor.java:203)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeBeforeEachMethods(TestMethodTestDescriptor.java:172)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:69)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:992)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	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.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
	at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
	at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
	at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
	at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:119)
	at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:94)
	at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:89)
	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:62)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	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 jdk.proxy1/jdk.proxy1.$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-12-06 06:51:52,789] WARN Unable to reconnect to ZooKeeper service, session 0x100829549c40002 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 06:51:52,790] WARN Session 0x100829549c40002 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x100829549c40002 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 06:51:52,963] WARN Unable to reconnect to ZooKeeper service, session 0x100829549c40003 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 06:51:52,963] WARN Session 0x100829549c40003 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x100829549c40003 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 06:51:52,966] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.net.SocketTimeoutException: Failed to connect within 1500 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 06:51:53,236] WARN Unable to reconnect to ZooKeeper service, session 0x100829549c40001 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 06:51:53,236] WARN Session 0x100829549c40001 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x100829549c40001 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 06:51:53,292] WARN Unable to reconnect to ZooKeeper service, session 0x100829549c40000 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 06:51:53,292] WARN Session 0x100829549c40000 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x100829549c40000 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 06:51:53,347] WARN Unable to reconnect to ZooKeeper service, session 0x100829549c40004 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 06:51:53,347] WARN Session 0x100829549c40004 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x100829549c40004 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 06:51:53,359] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
org.apache.kafka.common.errors.DisconnectException: NetworkClient is no longer active, state is CLOSING
[2023-12-06 06:51:53,360] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type: UpdateMetadataRequest=, controllerId=0, controllerEpoch=1, kraftController=false, type=UNKNOWN, brokerEpoch=98, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=1, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45709, host='localhost', listener='SASL_SSL', securityProtocol=3)], rack=null), UpdateMetadataBroker(id=2, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45311, host='localhost', listener='SASL_SSL', securityProtocol=3)], rack=null), UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=36039, host='localhost', listener='SASL_SSL', securityProtocol=3)], rack=null)) to broker localhost:45311 (id: 2 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72)
java.lang.InterruptedException
	at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1081)
	at java.base/java.util.concurrent.CountDownLatch.await(CountDownLatch.java:276)
	at org.apache.kafka.server.util.ShutdownableThread.pause(ShutdownableThread.java:117)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:239)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 06:51:53,363] WARN Unable to reconnect to ZooKeeper service, session 0x100829549c40005 has expired (org.apache.zookeeper.ClientCnxn:1437)
[2023-12-06 06:51:53,363] WARN Session 0x100829549c40005 for server localhost/127.0.0.1:36781, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300)
org.apache.zookeeper.ClientCnxn$SessionExpiredException: Unable to reconnect to ZooKeeper service, session 0x100829549c40005 has expired
	at org.apache.zookeeper.ClientCnxn$SendThread.onConnected(ClientCnxn.java:1438)
	at org.apache.zookeeper.ClientCnxnSocket.readConnectResult(ClientCnxnSocket.java:154)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:86)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289)
[2023-12-06 06:51:54,076] WARN [RequestSendThread controllerId=1] Controller 1's connection to broker localhost:45311 (id: 2 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
org.apache.kafka.common.errors.DisconnectException: NetworkClient is no longer active, state is CLOSING
[2023-12-06 06:51:54,076] WARN [RequestSendThread controllerId=1] Controller 1 epoch 2 fails to send request (type: UpdateMetadataRequest=, controllerId=1, controllerEpoch=2, kraftController=false, type=UNKNOWN, brokerEpoch=117, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=1, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45709, host='localhost', listener='SASL_SSL', securityProtocol=3)], rack=null), UpdateMetadataBroker(id=2, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45311, host='localhost', listener='SASL_SSL', securityProtocol=3)], rack=null), UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=36039, host='localhost', listener='SASL_SSL', securityProtocol=3)], rack=null)) to broker localhost:45311 (id: 2 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72)
java.lang.InterruptedException
	at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1081)
	at java.base/java.util.concurrent.CountDownLatch.await(CountDownLatch.java:276)
	at org.apache.kafka.server.util.ShutdownableThread.pause(ShutdownableThread.java:117)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:239)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 06:51:54,217] WARN [KafkaServer id=0] Connection to node 1 (localhost/127.0.0.1:45709) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient:830)
[2023-12-06 06:51:54,217] WARN [KafkaServer id=0] Error during controlled shutdown, possibly because leader movement took longer than the configured controller.socket.timeout.ms and/or request.timeout.ms: Connection to localhost:45709 (id: 1 rack: null) failed. (kafka.server.KafkaServer:70)
[2023-12-06 06:51:54,318] WARN [KafkaServer id=0] Connection to node 1 (localhost/127.0.0.1:45709) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient:830)
[2023-12-06 06:51:54,319] WARN [KafkaServer id=0] Error during controlled shutdown, possibly because leader movement took longer than the configured controller.socket.timeout.ms and/or request.timeout.ms: Connection to localhost:45709 (id: 1 rack: null) failed. (kafka.server.KafkaServer:70)
[2023-12-06 06:51:54,420] WARN [KafkaServer id=0] Connection to node 1 (localhost/127.0.0.1:45709) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient:830)
[2023-12-06 06:51:54,420] WARN [KafkaServer id=0] Error during controlled shutdown, possibly because leader movement took longer than the configured controller.socket.timeout.ms and/or request.timeout.ms: Connection to localhost:45709 (id: 1 rack: null) failed. (kafka.server.KafkaServer:70)
[2023-12-06 06:51:54,421] WARN [KafkaServer id=0] Proceeding to do an unclean shutdown as all the controlled shutdown attempts failed (kafka.server.KafkaServer:70)
[2023-12-06 06:51:55,543] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36039) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient:830)
[2023-12-06 06:51:55,543] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36039 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72)
java.io.IOException: Connection to localhost:36039 (id: 0 rack: null) failed.
	at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)
[2023-12-06 06:51:55,585] WARN [RequestSendThread controllerId=0] Controller 0 epoch 3 fails to send request (type: UpdateMetadataRequest=, controllerId=0, controllerEpoch=3, kraftController=false, type=UNKNOWN, brokerEpoch=113, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=36039, host='localhost', listener='SASL_SSL', securityProtocol=3)], rack=null)) to broker localhost:36039 (id: 0 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72)
java.lang.InterruptedException
	at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1081)
	at java.base/java.util.concurrent.CountDownLatch.await(CountDownLatch.java:276)
	at org.apache.kafka.server.util.ShutdownableThread.pause(ShutdownableThread.java:117)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:239)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131)