Created
December 19, 2023 13:41
-
-
Save stanislavkozlovski/f84f045510fbf1dbd3cd5b321277406a to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [2023-12-06 07:27:29,958] WARN maxCnxns is not configured, using default value 0. (org.apache.zookeeper.server.ServerCnxnFactory:309) | |
| [2023-12-06 07:30:28,911] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37809 (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 07:31:01,656] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type: UpdateMetadataRequest=, controllerId=0, controllerEpoch=1, kraftController=false, type=UNKNOWN, brokerEpoch=46, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=1, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=37809, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45627, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null)) to broker localhost:37809 (id: 1 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72) | |
| java.io.IOException: Connection to 1 was disconnected before the response was read | |
| at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:258) | |
| at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131) | |
| [2023-12-06 07:31:04,304] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37809 (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 07:34:24,958] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:34801 (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 07:34:56,901] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type: UpdateMetadataRequest=, controllerId=0, controllerEpoch=1, kraftController=false, type=UNKNOWN, brokerEpoch=62, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=1, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=37809, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45627, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=2, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=34801, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null)) to broker localhost:34801 (id: 2 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72) | |
| java.io.IOException: Connection to 2 was disconnected before the response was read | |
| at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:258) | |
| at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131) | |
| [2023-12-06 07:35:01,959] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:34801 (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 07:35:38,907] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type: UpdateMetadataRequest=, controllerId=0, controllerEpoch=1, kraftController=false, type=UNKNOWN, brokerEpoch=62, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=1, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=37809, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45627, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=2, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=34801, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null)) to broker localhost:34801 (id: 2 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72) | |
| java.io.IOException: Connection to 2 was disconnected before the response was read | |
| at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:258) | |
| at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131) | |
| [2023-12-06 07:35:44,652] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:34801 (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 07:36:21,959] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type: UpdateMetadataRequest=, controllerId=0, controllerEpoch=1, kraftController=false, type=UNKNOWN, brokerEpoch=62, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=1, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=37809, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45627, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=2, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=34801, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null)) to broker localhost:34801 (id: 2 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72) | |
| java.io.IOException: Connection to 2 was disconnected before the response was read | |
| at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:258) | |
| at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131) | |
| [2023-12-06 07:36:39,299] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:34801 (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 07:37:19,008] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type: UpdateMetadataRequest=, controllerId=0, controllerEpoch=1, kraftController=false, type=UNKNOWN, brokerEpoch=62, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=1, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=37809, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45627, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=2, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=34801, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null)) to broker localhost:34801 (id: 2 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72) | |
| java.io.IOException: Connection to 2 was disconnected before the response was read | |
| at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:258) | |
| at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131) | |
| [2023-12-06 07:37:34,596] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:34801 (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 07:38:26,346] WARN Client session timed out, have not heard from server in 10824ms for session id 0x100830f12e20001 (org.apache.zookeeper.ClientCnxn:1256) | |
| [2023-12-06 07:38:26,998] WARN Client session timed out, have not heard from server in 10249ms for session id 0x100830f12e20000 (org.apache.zookeeper.ClientCnxn:1256) | |
| [2023-12-06 07:38:38,951] WARN Session 0x100830f12e20000 for server localhost/127.0.0.1:42241, 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 10249ms for session id 0x100830f12e20000 | |
| at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257) | |
| [2023-12-06 07:38:34,596] WARN [RequestSendThread controllerId=0] Controller 0 epoch 1 fails to send request (type=LeaderAndIsRequest, controllerId=0, controllerEpoch=1, brokerEpoch=46, partitionStates=[LeaderAndIsrPartitionState(topicName='__consumer_offsets', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], partitionEpoch=0, replicas=[1], addingReplicas=[], removingReplicas=[], isNew=true, leaderRecoveryState=0)], topicIds={__consumer_offsets=9YmvZSKPRhKeWJnYNM-qGA}, liveLeaders=(localhost:37809 (id: 1 rack: null))) to broker localhost:37809 (id: 1 rack: null). Reconnecting to broker. (kafka.controller.RequestSendThread:72) | |
| java.io.IOException: Connection to 1 was disconnected before the response was read | |
| at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:258) | |
| at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:131) | |
| [2023-12-06 07:38:34,596] WARN Session 0x100830f12e20001 for server /127.0.0.1:42241, 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 10824ms for session id 0x100830f12e20001 | |
| at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257) | |
| [2023-12-06 07:38:46,898] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:37809 (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 07:38:46,899] WARN Session 0x100830f12e20001 for server /127.0.0.1:42241, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. (org.apache.zookeeper.ClientCnxn:1300) | |
| EndOfStreamException: Unable to read additional data from server sessionid 0x100830f12e20001, likely server has closed socket | |
| at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) | |
| at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) | |
| at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1289) | |
| [2023-12-06 07:38:48,945] WARN Unable to reconnect to ZooKeeper service, session 0x100830f12e20000 has expired (org.apache.zookeeper.ClientCnxn:1437) | |
| [2023-12-06 07:39:06,008] WARN Session 0x100830f12e20000 for server localhost/127.0.0.1:42241, 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 0x100830f12e20000 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 07:39:08,546] WARN Unable to reconnect to ZooKeeper service, session 0x100830f12e20001 has expired (org.apache.zookeeper.ClientCnxn:1437) | |
| [2023-12-06 07:39:10,402] WARN Session 0x100830f12e20001 for server /127.0.0.1:42241, 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 0x100830f12e20001 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 07:39:10,498] WARN CancelledKeyException causing close of session: 0x100830f12e20001 (org.apache.zookeeper.server.NIOServerCnxn:370) | |
| [2023-12-06 07:39:36,852] WARN Client session timed out, have not heard from server in 10701ms for session id 0x100830f12e20003 (org.apache.zookeeper.ClientCnxn:1256) | |
| [2023-12-06 07:39:37,547] WARN Client session timed out, have not heard from server in 10771ms for session id 0x100830f12e20004 (org.apache.zookeeper.ClientCnxn:1256) | |
| [2023-12-06 07:39:41,309] WARN Session 0x100830f12e20004 for server /127.0.0.1:42241, 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 10771ms for session id 0x100830f12e20004 | |
| at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257) | |
| [2023-12-06 07:39:41,150] WARN Session 0x100830f12e20003 for server /127.0.0.1:42241, 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 10701ms for session id 0x100830f12e20003 | |
| at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1257) | |
| [2023-12-06 07:41:04,302] 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: Failed to connect within 1500 ms (kafka.server.KafkaServer:70) | |
| [2023-12-06 07:41:42,199] WARN [KafkaServer id=0] Connection to node 1 (localhost/127.0.0.1:37809) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient:830) | |
| [2023-12-06 07:42:00,241] 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: Failed to connect within 1500 ms (kafka.server.KafkaServer:70) | |
| [2023-12-06 07:42:16,842] WARN [RequestSendThread controllerId=1] Controller 1's connection to broker localhost:37809 (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 07:42:17,602] 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: Failed to connect within 1500 ms (kafka.server.KafkaServer:70) | |
| [2023-12-06 07:42:20,755] WARN [RequestSendThread controllerId=1] Controller 1 epoch 2 fails to send request (type: UpdateMetadataRequest=, controllerId=1, controllerEpoch=2, kraftController=false, type=UNKNOWN, brokerEpoch=46, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=1, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=37809, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null), UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45627, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null)) to broker localhost:37809 (id: 1 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 07:42:32,895] WARN [KafkaServer id=0] Proceeding to do an unclean shutdown as all the controlled shutdown attempts failed (kafka.server.KafkaServer:70) | |
| [2023-12-06 07:42:56,101] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45627 (id: 0 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 07:43:05,852] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:45627) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient:830) | |
| [2023-12-06 07:43:09,596] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45627 (id: 0 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 07:43:17,997] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (localhost/127.0.0.1:45627) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient:830) | |
| [2023-12-06 07:43:21,647] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45627 (id: 0 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 07:43:30,242] WARN [RequestSendThread controllerId=0] Controller 0's connection to broker localhost:45627 (id: 0 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 07:43:34,044] WARN [RequestSendThread controllerId=0] Controller 0 epoch 3 fails to send request (type: UpdateMetadataRequest=, controllerId=0, controllerEpoch=3, kraftController=false, type=UNKNOWN, brokerEpoch=74, partitionStates=[], liveBrokers=UpdateMetadataBroker(id=0, v0Host='', v0Port=0, endpoints=[UpdateMetadataEndpoint(port=45627, host='localhost', listener='PLAINTEXT', securityProtocol=0)], rack=null)) to broker localhost:45627 (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) | |
| [2023-12-06 07:44:08,847] WARN Client session timed out, have not heard from server in 10352ms for session id 0x100830f12e20005 (org.apache.zookeeper.ClientCnxn:1256) | |
| [2023-12-06 07:44:40,852] WARN Close of session 0x100830f12e20005 (org.apache.zookeeper.server.NIOServerCnxn:388) | |
| java.nio.channels.ClosedChannelException | |
| at java.base/sun.nio.ch.SocketChannelImpl.ensureOpenAndConnected(SocketChannelImpl.java:215) | |
| at java.base/sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:403) | |
| at org.apache.zookeeper.server.NIOServerCnxn.readPayload(NIOServerCnxn.java:177) | |
| at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:354) | |
| at org.apache.zookeeper.server.NIOServerCnxnFactory$IOWorkRequest.doWork(NIOServerCnxnFactory.java:508) | |
| at org.apache.zookeeper.server.WorkerService$ScheduledWorkRequest.run(WorkerService.java:153) | |
| at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) | |
| at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) | |
| at java.base/java.lang.Thread.run(Thread.java:833) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment