Error org.apache.kafka.common.errors.TopicExistsException: Topic '__consumer_offsets' already exists. Stacktrace org.apache.kafka.common.errors.TopicExistsException: Topic '__consumer_offsets' already exists. Standard Output [2023-05-05 22:32:48,447] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:32:48,490] WARN No meta.properties file under dir /tmp/kafka-14330115832087574516/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:32:53,411] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:32:53,454] WARN No meta.properties file under dir /tmp/kafka-13331413389042353333/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:32:57,552] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:32:57,593] WARN No meta.properties file under dir /tmp/kafka-14483814572758361513/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:04,355] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:04,419] WARN No meta.properties file under dir /tmp/kafka-3483559678690943068/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:08,879] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:08,931] WARN No meta.properties file under dir /tmp/kafka-4743256589933135844/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:10,208] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:10,257] WARN No meta.properties file under dir /tmp/kafka-54491634174285816/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:10,660] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:37833) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:10,661] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37833 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:37833 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:10,762] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:37833) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:10,762] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37833 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:37833 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:10,863] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:37833) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:10,864] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37833 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:37833 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:10,965] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:37833) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:10,965] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37833 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:37833 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:11,067] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:37833) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:11,067] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37833 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:37833 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:11,168] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:37833) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:11,169] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37833 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:37833 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:11,270] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:37833) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:11,270] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37833 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:37833 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:11,301] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type=LeaderAndIsRequest, controllerId=0, controllerEpoch=1, brokerEpoch=26, partitionStates=[LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=3, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=4, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0)], topicIds={__consumer_offsets=WzZksHfjQPu3mlTBSAtZRw}, liveLeaders=(localhost:37833 (id: 0 rack: null))) to broker localhost:37833 (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:113) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:237) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:11,533] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:11,664] WARN No meta.properties file under dir /tmp/kafka-2860689384107135893/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:15,959] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:16,000] WARN No meta.properties file under dir /tmp/kafka-6280605846028210222/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:16,487] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:38867) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:16,487] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:38867 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:38867 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:16,588] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:38867) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:16,588] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:38867 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:38867 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:16,689] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:38867) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:16,690] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:38867 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:38867 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:16,791] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:38867) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:16,791] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:38867 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:38867 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:16,892] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:38867) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:16,893] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:38867 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:38867 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:16,994] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:38867) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:16,994] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:38867 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:38867 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:17,095] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:38867) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:33:17,095] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:38867 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:38867 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:17,171] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type=LeaderAndIsRequest, controllerId=0, controllerEpoch=1, brokerEpoch=26, partitionStates=[LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=3, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=4, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0)], topicIds={__consumer_offsets=FVYU5coORyOhkyeNPOec8w}, liveLeaders=(localhost:38867 (id: 0 rack: null))) to broker localhost:38867 (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:113) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:237) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:33:17,395] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:17,449] WARN No meta.properties file under dir /tmp/kafka-502435518034892013/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:21,043] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:21,102] WARN No meta.properties file under dir /tmp/kafka-4546353445590619457/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:24,960] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:25,002] WARN No meta.properties file under dir /tmp/kafka-6467011523193278203/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:28,398] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:28,470] WARN No meta.properties file under dir /tmp/kafka-4684567497866474283/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:38,493] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:38,539] WARN No meta.properties file under dir /tmp/kafka-13496269193754325621/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:48,792] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:48,850] WARN No meta.properties file under dir /tmp/kafka-6958766797235822287/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:53,637] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:53,701] WARN No meta.properties file under dir /tmp/kafka-5495234289345550421/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:33:57,606] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:33:57,661] WARN No meta.properties file under dir /tmp/kafka-4424126066703888311/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:02,087] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:02,156] WARN No meta.properties file under dir /tmp/kafka-6175659366002727326/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:04,440] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:04,487] WARN No meta.properties file under dir /tmp/kafka-8896755174386646047/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:05,042] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:42159) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:05,043] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:42159 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:42159 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:05,144] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:42159) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:05,145] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:42159 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:42159 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:05,246] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:42159) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:05,246] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:42159 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:42159 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:05,347] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:42159) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:05,348] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:42159 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:42159 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:05,449] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:42159) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:05,449] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:42159 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:42159 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:05,550] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:42159) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:05,551] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:42159 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:42159 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:05,652] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:42159) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:05,652] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:42159 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:42159 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:05,718] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type=LeaderAndIsRequest, controllerId=0, controllerEpoch=1, brokerEpoch=26, partitionStates=[LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=3, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=4, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0)], topicIds={__consumer_offsets=neqo3H8vTAeVbTbAwY-8kw}, liveLeaders=(localhost:42159 (id: 0 rack: null))) to broker localhost:42159 (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:113) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:237) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:05,955] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:06,005] WARN No meta.properties file under dir /tmp/kafka-4018998030990232752/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:10,512] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:10,555] WARN No meta.properties file under dir /tmp/kafka-18114384712757250806/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:16,700] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:16,753] WARN No meta.properties file under dir /tmp/kafka-6566314773378909555/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:20,883] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:20,933] WARN No meta.properties file under dir /tmp/kafka-5299838268969888680/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:23,776] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:23,817] WARN No meta.properties file under dir /tmp/kafka-8060201588377206108/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:32,310] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:32,346] WARN No meta.properties file under dir /tmp/kafka-17417685748117050675/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:32,811] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type=LeaderAndIsRequest, controllerId=0, controllerEpoch=1, brokerEpoch=26, partitionStates=[LeaderAndIsrPartitionState(topicName='primary.checkpoints.internal', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0)], topicIds={primary.checkpoints.internal=SQbNYFwmSMufreJ9mOefCw}, liveLeaders=(localhost:36139 (id: 0 rack: null))) to broker localhost:36139 (id: 0 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to 0 was disconnected before the response was read at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:99) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:256) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:32,912] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:32,912] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,013] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:33,013] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,114] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:33,115] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,216] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:33,216] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,317] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:33,318] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,418] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:33,419] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,520] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:33,520] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,621] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:33,621] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,723] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:33,723] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,824] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36139) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:34:33,824] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36139 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36139 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:33,848] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type=LeaderAndIsRequest, controllerId=0, controllerEpoch=1, brokerEpoch=26, partitionStates=[LeaderAndIsrPartitionState(topicName='primary.checkpoints.internal', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0)], topicIds={primary.checkpoints.internal=SQbNYFwmSMufreJ9mOefCw}, liveLeaders=(localhost:36139 (id: 0 rack: null))) to broker localhost:36139 (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:113) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:237) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:34:34,071] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:34,112] WARN No meta.properties file under dir /tmp/kafka-17911886774454729585/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:38,891] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:38,961] WARN No meta.properties file under dir /tmp/kafka-8553273206023554880/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID test.group foo 0 0 0 0 - - - GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID test.group--offsets foo 0 0 0 0 - - - GROUP COORDINATOR (ID) ASSIGNMENT-STRATEGY STATE #MEMBERS test.group--state localhost:36001 (0) Empty 0 [2023-05-05 22:34:45,157] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:45,204] WARN No meta.properties file under dir /tmp/kafka-1498023475476397573/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:34:51,149] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:34:51,186] WARN No meta.properties file under dir /tmp/kafka-15481352901837099597/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:35:01,269] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:35:01,305] WARN No meta.properties file under dir /tmp/kafka-3018422637717018038/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:35:01,730] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36373) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:35:01,731] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36373 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36373 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:01,832] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36373) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:35:01,832] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36373 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36373 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:01,934] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36373) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:35:01,934] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36373 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36373 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:02,035] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36373) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:35:02,035] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36373 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36373 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:02,137] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36373) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:35:02,137] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36373 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36373 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:02,238] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36373) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:35:02,238] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36373 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36373 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:02,339] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36373) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:35:02,340] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36373 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36373 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:02,441] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36373) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:35:02,441] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36373 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36373 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:02,542] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:36373) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:814) [2023-05-05 22:35:02,542] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:36373 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread:72) java.io.IOException: Connection to localhost:36373 (id: 0 rack: null) failed. at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:296) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:249) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:02,594] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type=LeaderAndIsRequest, controllerId=0, controllerEpoch=1, brokerEpoch=26, partitionStates=[LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=3, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=4, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0), LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], partitionEpoch=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0)], topicIds={__consumer_offsets=Hm1KOJGTRlqkHBg9Cb2qRw}, liveLeaders=(localhost:36373 (id: 0 rack: null))) to broker localhost:36373 (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:113) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:237) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127) [2023-05-05 22:35:02,832] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:35:02,950] WARN No meta.properties file under dir /tmp/kafka-17136934149079862895/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:35:08,445] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:35:08,508] WARN No meta.properties file under dir /tmp/kafka-16725411451949613827/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-05 22:35:12,088] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-05 22:35:12,135] WARN No meta.properties file under dir /tmp/kafka-2064658193056061231/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) [2023-05-06 00:14:51,012] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) [2023-05-06 00:14:51,664] WARN No meta.properties file under dir /tmp/kafka-1352733061773321524/meta.properties (kafka.server.BrokerMetadataCheckpoint:70) Standard Error Option [describe] takes at most one of these options: [members], [offsets], [state] Option Description ------ ----------- --all-groups Apply to all consumer groups. --all-topics Consider all topics assigned to a group in the `reset-offsets` process. --bootstrap-server --by-duration Reset offsets to offset by duration from current timestamp. Format: 'PnDTnHnMnS' --command-config passed to Admin Client and Consumer. --delete Pass in groups to delete topic partition offsets and ownership information over the entire consumer group. For instance --group g1 -- group g2 --delete-offsets Delete offsets of consumer group. Supports one consumer group at the time, and multiple topics. --describe Describe consumer group and list offset lag (number of messages not yet processed) related to given group. --dry-run Only show results without executing changes on Consumer Groups. Supported operations: reset-offsets. --execute Execute operation. Supported operations: reset-offsets. --export Export operation execution to a CSV file. Supported operations: reset- offsets. --from-file Reset offsets to values defined in CSV file. --group The consumer group we wish to act on. --help Print usage information. --list List all consumer groups. --members Describe members of the group. This option may be used with '--describe' and '--bootstrap-server' options only. Example: --bootstrap-server localhost: 9092 --describe --group group1 -- members --offsets Describe the group and list all topic partitions in the group along with their offset lag. This is the default sub-action of and may be used with '--describe' and '-- bootstrap-server' options only. Example: --bootstrap-server localhost: 9092 --describe --group group1 -- offsets --reset-offsets Reset offsets of consumer group. Supports one consumer group at the time, and instances should be inactive Has 2 execution options: --dry-run (the default) to plan which offsets to reset, and --execute to update the offsets. Additionally, the -- export option is used to export the results to a CSV format. You must choose one of the following reset specifications: --to-datetime, --by-duration, --to-earliest, --to- latest, --shift-by, --from-file, -- to-current, --to-offset. To define the scope use --all-topics or --topic. One scope must be specified unless you use '--from- file'. --shift-by Reset offsets shifting current offset by 'n', where 'n' can be positive or negative. --state [String] When specified with '--describe', includes the state of the group. Example: --bootstrap-server localhost: 9092 --describe --group group1 -- state When specified with '--list', it displays the state of all groups. It can also be used to list groups with specific states. Example: --bootstrap-server localhost: 9092 --list --state stable,empty This option may be used with '-- describe', '--list' and '--bootstrap- server' options only. --timeout The timeout that can be set for some use cases. For example, it can be used when describing the group to specify the maximum amount of time in milliseconds to wait before the group stabilizes (when the group is just created, or is going through some changes). (default: 5000) --to-current Reset offsets to current offset. --to-datetime Reset offsets to offset from datetime. Format: 'YYYY-MM-DDTHH:mm:SS.sss' --to-earliest Reset offsets to earliest offset. --to-latest Reset offsets to latest offset. --to-offset Reset offsets to a specific offset. --topic The topic whose consumer group information should be deleted or topic whose should be included in the reset offset process. In `reset- offsets` case, partitions can be specified using this format: `topic1: 0,1,2`, where 0,1,2 are the partition to be included in the process. Reset-offsets also supports multiple topic inputs. --verbose Provide additional information, if any, when describing the group. This option may be used with '-- offsets'/'--members'/'--state' and '--bootstrap-server' options only. Example: --bootstrap-server localhost: 9092 --describe --group group1 -- members --verbose --version Display Kafka version. Option [describe] does not take a value for [state] Option Description ------ ----------- --all-groups Apply to all consumer groups. --all-topics Consider all topics assigned to a group in the `reset-offsets` process. --bootstrap-server --by-duration Reset offsets to offset by duration from current timestamp. Format: 'PnDTnHnMnS' --command-config passed to Admin Client and Consumer. --delete Pass in groups to delete topic partition offsets and ownership information over the entire consumer group. For instance --group g1 -- group g2 --delete-offsets Delete offsets of consumer group. Supports one consumer group at the time, and multiple topics. --describe Describe consumer group and list offset lag (number of messages not yet processed) related to given group. --dry-run Only show results without executing changes on Consumer Groups. Supported operations: reset-offsets. --execute Execute operation. Supported operations: reset-offsets. --export Export operation execution to a CSV file. Supported operations: reset- offsets. --from-file Reset offsets to values defined in CSV file. --group The consumer group we wish to act on. --help Print usage information. --list List all consumer groups. --members Describe members of the group. This option may be used with '--describe' and '--bootstrap-server' options only. Example: --bootstrap-server localhost: 9092 --describe --group group1 -- members --offsets Describe the group and list all topic partitions in the group along with their offset lag. This is the default sub-action of and may be used with '--describe' and '-- bootstrap-server' options only. Example: --bootstrap-server localhost: 9092 --describe --group group1 -- offsets --reset-offsets Reset offsets of consumer group. Supports one consumer group at the time, and instances should be inactive Has 2 execution options: --dry-run (the default) to plan which offsets to reset, and --execute to update the offsets. Additionally, the -- export option is used to export the results to a CSV format. You must choose one of the following reset specifications: --to-datetime, --by-duration, --to-earliest, --to- latest, --shift-by, --from-file, -- to-current, --to-offset. To define the scope use --all-topics or --topic. One scope must be specified unless you use '--from- file'. --shift-by Reset offsets shifting current offset by 'n', where 'n' can be positive or negative. --state [String] When specified with '--describe', includes the state of the group. Example: --bootstrap-server localhost: 9092 --describe --group group1 -- state When specified with '--list', it displays the state of all groups. It can also be used to list groups with specific states. Example: --bootstrap-server localhost: 9092 --list --state stable,empty This option may be used with '-- describe', '--list' and '--bootstrap- server' options only. --timeout The timeout that can be set for some use cases. For example, it can be used when describing the group to specify the maximum amount of time in milliseconds to wait before the group stabilizes (when the group is just created, or is going through some changes). (default: 5000) --to-current Reset offsets to current offset. --to-datetime Reset offsets to offset from datetime. Format: 'YYYY-MM-DDTHH:mm:SS.sss' --to-earliest Reset offsets to earliest offset. --to-latest Reset offsets to latest offset. --to-offset Reset offsets to a specific offset. --topic The topic whose consumer group information should be deleted or topic whose should be included in the reset offset process. In `reset- offsets` case, partitions can be specified using this format: `topic1: 0,1,2`, where 0,1,2 are the partition to be included in the process. Reset-offsets also supports multiple topic inputs. --verbose Provide additional information, if any, when describing the group. This option may be used with '-- offsets'/'--members'/'--state' and '--bootstrap-server' options only. Example: --bootstrap-server localhost: 9092 --describe --group group1 -- members --verbose --version Display Kafka version.