[2021-12-06 18:00:06,805] INFO [Log partition=__consumer_offsets-5, dir=/var/lib/kafka] Deleting segment files LogSegment(baseOffset=0, size=29092, lastModifiedTime=1638208410089, largestRecordTimestamp=Some(1638208410091)) (kafka.log.Log) [2021-12-06 18:00:06,806] INFO Deleted log /var/lib/kafka/__consumer_offsets-5/00000000000000000000.log.deleted. (kafka.log.LogSegment) [2021-12-06 18:00:06,806] INFO Deleted offset index /var/lib/kafka/__consumer_offsets-5/00000000000000000000.index.deleted. (kafka.log.LogSegment) [2021-12-06 18:00:06,807] INFO Deleted time index /var/lib/kafka/__consumer_offsets-5/00000000000000000000.timeindex.deleted. (kafka.log.LogSegment) [2021-12-06 18:31:07,099] WARN Client session timed out, have not heard from server in 12006ms for sessionid 0x10000039563000f (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:07,099] INFO Client session timed out, have not heard from server in 12006ms for sessionid 0x10000039563000f, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:09,185] WARN Client session timed out, have not heard from server in 12002ms for sessionid 0x100000395630011 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:09,185] INFO Client session timed out, have not heard from server in 12002ms for sessionid 0x100000395630011, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:11,387] WARN SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/etc/kafka/kafka_server_jaas.conf'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it. (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:11,387] INFO Opening socket connection to server ===ZOOKEEPER_DOMAIN_3===:2181 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:11,387] ERROR [ZooKeeperClient Kafka server] Auth failed. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:11,571] WARN SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/etc/kafka/kafka_server_jaas.conf'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it. (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:11,572] INFO Opening socket connection to server ===ZOOKEEPER_DOMAIN_3===:2181 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:11,572] ERROR [ZooKeeperClient ACL authorizer] Auth failed. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:12,389] INFO [ZooKeeperClient Kafka server] Reinitializing due to auth failure. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:12,400] INFO Creating /brokers/ids/3 (is it secure? false) (kafka.zk.KafkaZkClient) [2021-12-06 18:31:12,572] INFO [ZooKeeperClient ACL authorizer] Reinitializing due to auth failure. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:13,200] WARN Client session timed out, have not heard from server in 6001ms for sessionid 0x10000039563000f (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:13,200] INFO Client session timed out, have not heard from server in 6001ms for sessionid 0x10000039563000f, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:13,303] INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:13,303] INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:13,303] INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:14,135] WARN SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/etc/kafka/kafka_server_jaas.conf'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it. (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,135] ERROR [ZooKeeperClient Kafka server] Auth failed. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:14,135] INFO Opening socket connection to server ===ZOOKEEPER_DOMAIN_2===:2181 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,611] INFO Socket connection established, initiating session, client: /===IP_ADDRESS_1===:48308, server: ===ZOOKEEPER_DOMAIN_3===:2181 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,627] INFO Session establishment complete on server ===ZOOKEEPER_DOMAIN_3===:2181, sessionid = 0x100000395630011, negotiated timeout = 18000 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,628] INFO Socket connection established, initiating session, client: /===IP_ADDRESS_1===:56214, server: ===ZOOKEEPER_DOMAIN_2===:2181 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,629] WARN Unable to reconnect to ZooKeeper service, session 0x10000039563000f has expired (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,629] INFO Unable to reconnect to ZooKeeper service, session 0x10000039563000f has expired, closing socket connection (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,629] INFO EventThread shut down for session: 0x10000039563000f (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,631] INFO [ZooKeeperClient Kafka server] Session expired. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:14,632] ERROR [feature-zk-node-event-process-thread]: Failed to process feature ZK node change event. The broker will eventually exit. (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread) kafka.zookeeper.ZooKeeperClientExpiredException: Session expired either before or while waiting for connection at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:279) at kafka.zookeeper.ZooKeeperClient.$anonfun$waitUntilConnected$1(ZooKeeperClient.scala:261) at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:261) at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:1797) at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:1767) at kafka.zk.KafkaZkClient.retryRequestUntilConnected(KafkaZkClient.scala:1762) at kafka.zk.KafkaZkClient.getDataAndStat(KafkaZkClient.scala:771) at kafka.zk.KafkaZkClient.getDataAndVersion(KafkaZkClient.scala:755) at kafka.server.FinalizedFeatureChangeListener$FeatureCacheUpdater.updateLatestOrThrow(FinalizedFeatureChangeListener.scala:74) at kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread.doWork(FinalizedFeatureChangeListener.scala:147) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) [2021-12-06 18:31:14,667] INFO [ZooKeeperClient Kafka server] Initializing a new session to ===ZOOKEEPER_DOMAIN_2===:2181,===ZOOKEEPER_DOMAIN_1===:2181,===ZOOKEEPER_DOMAIN_3===:2181. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:14,632] ERROR Error while processing notification change for path = /config/changes (kafka.common.ZkNodeChangeNotificationListener) kafka.zookeeper.ZooKeeperClientExpiredException: Session expired either before or while waiting for connection at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:279) at kafka.zookeeper.ZooKeeperClient.$anonfun$waitUntilConnected$1(ZooKeeperClient.scala:261) at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:261) at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:1797) at kafka.zk.KafkaZkClient.retryRequestsUntilConnected(KafkaZkClient.scala:1767) at kafka.zk.KafkaZkClient.retryRequestUntilConnected(KafkaZkClient.scala:1762) at kafka.zk.KafkaZkClient.getChildren(KafkaZkClient.scala:786) at kafka.common.ZkNodeChangeNotificationListener.kafka$common$ZkNodeChangeNotificationListener$$processNotifications(ZkNodeChangeNotificationListener.scala:83) at kafka.common.ZkNodeChangeNotificationListener$ChangeNotification.process(ZkNodeChangeNotificationListener.scala:120) at kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread.doWork(ZkNodeChangeNotificationListener.scala:146) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) [2021-12-06 18:31:14,669] INFO Initiating client connection, connectString====ZOOKEEPER_DOMAIN_2===:2181,===ZOOKEEPER_DOMAIN_1===:2181,===ZOOKEEPER_DOMAIN_3===:2181 sessionTimeout=18000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@2a5b3fee (org.apache.zookeeper.ZooKeeper) [2021-12-06 18:31:14,670] INFO jute.maxbuffer value is 4194304 Bytes (org.apache.zookeeper.ClientCnxnSocket) [2021-12-06 18:31:14,670] INFO zookeeper.request.timeout value is 0. feature enabled= (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,670] INFO [feature-zk-node-event-process-thread]: Stopped (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread) [2021-12-06 18:31:14,673] INFO Creating /brokers/ids/3 (is it secure? false) (kafka.zk.KafkaZkClient) [2021-12-06 18:31:14,677] INFO [KafkaServer id=3] shutting down (kafka.server.KafkaServer) [2021-12-06 18:31:14,678] WARN SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/etc/kafka/kafka_server_jaas.conf'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it. (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,679] INFO Opening socket connection to server ===ZOOKEEPER_DOMAIN_1===:2181 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,679] ERROR [ZooKeeperClient Kafka server] Auth failed. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:14,685] INFO [KafkaServer id=3] Starting controlled shutdown (kafka.server.KafkaServer) [2021-12-06 18:31:14,687] INFO Socket connection established, initiating session, client: /===IP_ADDRESS_1===:55328, server: ===ZOOKEEPER_DOMAIN_1===:2181 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,699] INFO Session establishment complete on server ===ZOOKEEPER_DOMAIN_1===:2181, sessionid = 0x10000039564ec61, negotiated timeout = 18000 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:14,703] INFO Processing notification(s) to /config/changes (kafka.common.ZkNodeChangeNotificationListener) [2021-12-06 18:31:14,712] INFO Stat of the created znode at /brokers/ids/3 is: 4296405196,4296405196,1638815474704,1638815474704,1,0,0,72057609429249121,347,0,4296405196 (kafka.zk.KafkaZkClient) [2021-12-06 18:31:14,716] INFO Registered broker 3 at path /brokers/ids/3 with addresses: SASL_SSL://===KAFKA_BROKER_2===:9091,SASL_PLAINTEXT://===KAFKA_BROKER_2===:9092, czxid (broker epoch): 4296405196 (kafka.zk.KafkaZkClient) [2021-12-06 18:31:14,872] INFO [ReplicaFetcherManager on broker 3] Removed fetcher for partitions HashSet(__consumer_offsets-13, __consumer_offsets-46, __consumer_offsets-9, __consumer_offsets-42, __consumer_offsets-21, __consumer_offsets-17, __consumer_offsets-30, __consumer_offsets-26, __consumer_offsets-5, __consumer_offsets-38, __consumer_offsets-1, __consumer_offsets-34, __consumer_offsets-16, __consumer_offsets-45, __consumer_offsets-12, __consumer_offsets-41, __consumer_offsets-24, __consumer_offsets-20, __consumer_offsets-49, __consumer_offsets-0, __consumer_offsets-29, __consumer_offsets-25, __consumer_offsets-8, __consumer_offsets-37, __consumer_offsets-4, __consumer_offsets-33, __consumer_offsets-15, __consumer_offsets-48, __consumer_offsets-11, __consumer_offsets-44, __consumer_offsets-23, __consumer_offsets-19, __consumer_offsets-32, __consumer_offsets-28, __consumer_offsets-7, __consumer_offsets-40, __consumer_offsets-3, __consumer_offsets-36, __consumer_offsets-47, __consumer_offsets-14, __consumer_offsets-43, __consumer_offsets-10, __consumer_offsets-22, __consumer_offsets-18, __consumer_offsets-31, __consumer_offsets-27, __consumer_offsets-39, __consumer_offsets-6, __consumer_offsets-35, __consumer_offsets-2) (kafka.server.ReplicaFetcherManager) [2021-12-06 18:31:14,896] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Shutting down (kafka.server.ReplicaFetcherThread) [2021-12-06 18:31:14,900] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=2003172423, epoch=4425354) to node 2: (org.apache.kafka.clients.FetchSessionHandler) java.io.IOException: Client was shutdown before response was read at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:109) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:110) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:217) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:141) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:140) at scala.Option.foreach(Option.scala:437) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:140) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:123) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) [2021-12-06 18:31:14,901] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Shutdown completed (kafka.server.ReplicaFetcherThread) [2021-12-06 18:31:14,901] INFO [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Stopped (kafka.server.ReplicaFetcherThread) [2021-12-06 18:31:14,904] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=1] Shutting down (kafka.server.ReplicaFetcherThread) [2021-12-06 18:31:14,905] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=1] Error sending fetch request (sessionId=1829614702, epoch=2033463) to node 1: (org.apache.kafka.clients.FetchSessionHandler) java.io.IOException: Client was shutdown before response was read at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:109) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:110) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:217) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:317) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:141) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:140) at scala.Option.foreach(Option.scala:437) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:140) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:123) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) [2021-12-06 18:31:14,908] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=1] Stopped (kafka.server.ReplicaFetcherThread) [2021-12-06 18:31:14,908] INFO [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=1] Shutdown completed (kafka.server.ReplicaFetcherThread) [2021-12-06 18:31:14,909] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 3 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,910] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,910] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-3. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,910] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 18 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,910] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,910] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-18. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,910] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 41 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,910] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-41 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,910] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-41. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,910] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 10 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,910] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,911] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-10. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,911] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 33 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,911] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,911] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-33. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,911] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 48 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,911] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,911] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-48. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,911] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 19 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,911] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,911] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-19. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,911] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 34 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,911] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-34 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,912] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-34. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,912] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 4 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,912] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,912] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-4. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,912] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 11 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,912] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-11 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,912] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-11. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,912] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 26 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,912] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,912] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-26. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,912] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 49 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,912] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,913] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-49. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,913] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 39 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,913] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,913] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-39. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,913] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 9 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,913] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,913] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-9. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,913] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 24 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,913] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,913] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-24. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,913] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 31 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,913] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,913] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-31. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,914] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 46 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,914] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,914] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-46. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,914] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 1 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,914] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-1 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,914] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-1. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,914] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 16 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,914] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,914] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-16. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,914] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 2 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,914] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,914] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-2. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,914] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 25 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,915] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,915] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-25. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,915] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 40 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,915] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,915] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-40. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,915] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 47 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,915] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,915] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-47. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,915] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 17 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,915] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-17 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,915] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-17. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,915] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 32 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,915] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,916] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-32. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,916] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 37 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,916] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-37 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,916] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-37. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,916] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 7 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,916] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,916] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-7. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,916] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 22 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,916] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,916] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-22. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,916] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 29 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,916] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,917] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-29. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,917] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 44 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,917] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,917] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-44. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,917] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 14 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,917] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,917] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-14. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,917] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 23 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,917] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,917] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-23. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,917] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 38 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,917] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,918] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-38. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,918] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 8 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,918] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,918] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-8. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,918] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 45 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,918] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,918] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-45. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,918] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 15 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,918] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,918] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-15. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,918] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 30 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,918] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,919] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-30. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,919] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 0 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,919] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,919] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-0. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,919] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 35 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,919] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,919] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-35. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,919] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 5 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,919] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,919] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-5. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,919] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 20 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,919] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,920] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-20. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,920] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 27 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,920] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,920] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-27. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,920] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 42 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,920] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,920] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-42. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,920] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 12 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,920] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,920] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-12. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,920] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 21 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,920] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,921] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-21. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,921] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 36 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,921] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,921] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-36. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,922] INFO [KafkaServer id=3] Controlled shutdown succeeded (kafka.server.KafkaServer) [2021-12-06 18:31:14,923] INFO [/config/changes-event-process-thread]: Shutting down (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-12-06 18:31:14,924] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 6 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,924] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,924] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-6. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,924] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 43 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,924] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-43 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,924] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-43. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,924] INFO [/config/changes-event-process-thread]: Stopped (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-12-06 18:31:14,924] INFO [/config/changes-event-process-thread]: Shutdown completed (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-12-06 18:31:14,925] INFO [SocketServer listenerType=ZK_BROKER, nodeId=3] Stopping socket server request processors (kafka.network.SocketServer) [2021-12-06 18:31:14,928] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 13 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,928] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-13 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,928] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-13. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,928] INFO [GroupCoordinator 3]: Resigned as the group coordinator for partition 28 (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:14,929] INFO [GroupMetadataManager brokerId=3] Scheduling unloading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,934] INFO [GroupMetadataManager brokerId=3] Finished unloading __consumer_offsets-28. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) [2021-12-06 18:31:14,952] INFO [SocketServer listenerType=ZK_BROKER, nodeId=3] Stopped socket server request processors (kafka.network.SocketServer) [2021-12-06 18:31:14,953] INFO [data-plane Kafka Request Handler on Broker 3], shutting down (kafka.server.KafkaRequestHandlerPool) [2021-12-06 18:31:14,957] INFO [data-plane Kafka Request Handler on Broker 3], shut down completely (kafka.server.KafkaRequestHandlerPool) [2021-12-06 18:31:14,960] INFO [ExpirationReaper-3-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,135] INFO [ZooKeeperClient Kafka server] Reinitializing due to auth failure. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:15,136] INFO Creating /brokers/ids/3 (is it secure? false) (kafka.zk.KafkaZkClient) [2021-12-06 18:31:15,143] INFO [ExpirationReaper-3-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,143] INFO [ExpirationReaper-3-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,144] INFO [KafkaApi-3] Shutdown complete. (kafka.server.KafkaApis) [2021-12-06 18:31:15,145] INFO [/kafka-acl-changes-event-process-thread]: Shutting down (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-12-06 18:31:15,145] INFO [/kafka-acl-changes-event-process-thread]: Stopped (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-12-06 18:31:15,145] INFO [/kafka-acl-changes-event-process-thread]: Shutdown completed (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-12-06 18:31:15,145] INFO [/kafka-acl-extended-changes-event-process-thread]: Shutting down (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-12-06 18:31:15,146] INFO [/kafka-acl-extended-changes-event-process-thread]: Stopped (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-12-06 18:31:15,146] INFO [/kafka-acl-extended-changes-event-process-thread]: Shutdown completed (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread) [2021-12-06 18:31:15,146] INFO [ZooKeeperClient ACL authorizer] Closing. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:15,152] INFO Stat of the created znode at /brokers/ids/3 is: 4296405196,4296405196,1638815474704,1638815474704,1,0,0,72057609429249121,347,0,4296405196 (kafka.zk.KafkaZkClient) [2021-12-06 18:31:15,153] INFO Registered broker 3 at path /brokers/ids/3 with addresses: SASL_SSL://===KAFKA_BROKER_2===:9091,SASL_PLAINTEXT://===KAFKA_BROKER_2===:9092, czxid (broker epoch): 4296405196 (kafka.zk.KafkaZkClient) [2021-12-06 18:31:15,266] INFO EventThread shut down for session: 0x100000395630011 (org.apache.zookeeper.ClientCnxn) [2021-12-06 18:31:15,266] INFO Session: 0x100000395630011 closed (org.apache.zookeeper.ZooKeeper) [2021-12-06 18:31:15,268] INFO [ZooKeeperClient ACL authorizer] Closed. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:15,268] INFO [ExpirationReaper-3-topic]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,311] INFO [ExpirationReaper-3-topic]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,311] INFO [ExpirationReaper-3-topic]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,313] INFO [TransactionCoordinator id=3] Shutting down. (kafka.coordinator.transaction.TransactionCoordinator) [2021-12-06 18:31:15,314] INFO [ProducerId Manager 3]: Shutdown complete: last producerId assigned 1000 (kafka.coordinator.transaction.ProducerIdManager) [2021-12-06 18:31:15,314] INFO [Transaction State Manager 3]: Shutdown complete (kafka.coordinator.transaction.TransactionStateManager) [2021-12-06 18:31:15,314] INFO [Transaction Marker Channel Manager 3]: Shutting down (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2021-12-06 18:31:15,314] INFO [Transaction Marker Channel Manager 3]: Shutdown completed (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2021-12-06 18:31:15,314] INFO [Transaction Marker Channel Manager 3]: Stopped (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2021-12-06 18:31:15,315] INFO [TransactionCoordinator id=3] Shutdown complete. (kafka.coordinator.transaction.TransactionCoordinator) [2021-12-06 18:31:15,316] INFO [GroupCoordinator 3]: Shutting down. (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:15,316] INFO [ExpirationReaper-3-Heartbeat]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,340] INFO [ExpirationReaper-3-Heartbeat]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,341] INFO [ExpirationReaper-3-Heartbeat]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,341] INFO [ExpirationReaper-3-Rebalance]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,468] INFO [ExpirationReaper-3-Rebalance]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,468] INFO [ExpirationReaper-3-Rebalance]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,469] INFO [GroupCoordinator 3]: Shutdown complete. (kafka.coordinator.group.GroupCoordinator) [2021-12-06 18:31:15,470] INFO [ReplicaManager broker=3] Shutting down (kafka.server.ReplicaManager) [2021-12-06 18:31:15,470] INFO [LogDirFailureHandler]: Shutting down (kafka.server.ReplicaManager$LogDirFailureHandler) [2021-12-06 18:31:15,471] INFO [LogDirFailureHandler]: Shutdown completed (kafka.server.ReplicaManager$LogDirFailureHandler) [2021-12-06 18:31:15,471] INFO [LogDirFailureHandler]: Stopped (kafka.server.ReplicaManager$LogDirFailureHandler) [2021-12-06 18:31:15,471] INFO [ReplicaFetcherManager on broker 3] shutting down (kafka.server.ReplicaFetcherManager) [2021-12-06 18:31:15,472] INFO [ReplicaFetcherManager on broker 3] shutdown completed (kafka.server.ReplicaFetcherManager) [2021-12-06 18:31:15,473] INFO [ReplicaAlterLogDirsManager on broker 3] shutting down (kafka.server.ReplicaAlterLogDirsManager) [2021-12-06 18:31:15,473] INFO [ReplicaAlterLogDirsManager on broker 3] shutdown completed (kafka.server.ReplicaAlterLogDirsManager) [2021-12-06 18:31:15,473] INFO [ExpirationReaper-3-Fetch]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,583] INFO [ExpirationReaper-3-Fetch]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,583] INFO [ExpirationReaper-3-Fetch]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,584] INFO [ExpirationReaper-3-Produce]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,680] INFO [ZooKeeperClient Kafka server] Reinitializing due to auth failure. (kafka.zookeeper.ZooKeeperClient) [2021-12-06 18:31:15,681] INFO Creating /brokers/ids/3 (is it secure? false) (kafka.zk.KafkaZkClient) [2021-12-06 18:31:15,696] INFO Stat of the created znode at /brokers/ids/3 is: 4296405196,4296405196,1638815474704,1638815474704,1,0,0,72057609429249121,347,0,4296405196 (kafka.zk.KafkaZkClient) [2021-12-06 18:31:15,696] INFO Registered broker 3 at path /brokers/ids/3 with addresses: SASL_SSL://===KAFKA_BROKER_2===:9091,SASL_PLAINTEXT://===KAFKA_BROKER_2===:9092, czxid (broker epoch): 4296405196 (kafka.zk.KafkaZkClient) [2021-12-06 18:31:15,712] INFO [ExpirationReaper-3-Produce]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,712] INFO [ExpirationReaper-3-Produce]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,712] INFO [ExpirationReaper-3-DeleteRecords]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,740] INFO [ExpirationReaper-3-DeleteRecords]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,740] INFO [ExpirationReaper-3-DeleteRecords]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,761] INFO [ExpirationReaper-3-ElectLeader]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,908] INFO [ExpirationReaper-3-ElectLeader]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,908] INFO [ExpirationReaper-3-ElectLeader]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2021-12-06 18:31:15,915] INFO [ReplicaManager broker=3] Shut down completely (kafka.server.ReplicaManager) [2021-12-06 18:31:15,915] INFO [broker-3-to-controller-send-thread]: Shutting down (kafka.server.BrokerToControllerRequestThread) [2021-12-06 18:31:15,915] INFO [broker-3-to-controller-send-thread]: Stopped (kafka.server.BrokerToControllerRequestThread) [2021-12-06 18:31:15,916] INFO [broker-3-to-controller-send-thread]: Shutdown completed (kafka.server.BrokerToControllerRequestThread) [2021-12-06 18:31:15,917] INFO Broker to controller channel manager for alterIsrChannel shutdown (kafka.server.BrokerToControllerChannelManagerImpl) [2021-12-06 18:31:15,918] INFO Shutting down. (kafka.log.LogManager) [2021-12-06 18:31:15,942] INFO [ProducerStateManager partition=__consumer_offsets-2] Writing producer snapshot at offset 11779295 (kafka.log.ProducerStateManager) [2021-12-06 18:31:15,953] INFO [ProducerStateManager partition=cookies-11] Writing producer snapshot at offset 1447462 (kafka.log.ProducerStateManager) [2021-12-06 18:31:15,962] INFO [ProducerStateManager partition=cookies-5] Writing producer snapshot at offset 1446913 (kafka.log.ProducerStateManager) [2021-12-06 18:31:15,971] INFO [ProducerStateManager partition=cookies-8] Writing producer snapshot at offset 1446420 (kafka.log.ProducerStateManager) [2021-12-06 18:31:15,976] INFO [ProducerStateManager partition=__consumer_offsets-5] Writing producer snapshot at offset 411 (kafka.log.ProducerStateManager) [2021-12-06 18:31:15,985] INFO [ProducerStateManager partition=cookies-2] Writing producer snapshot at offset 1447729 (kafka.log.ProducerStateManager) [2021-12-06 18:31:15,998] INFO Shutdown complete. (kafka.log.LogManager) [2021-12-06 18:31:16,007] INFO [feature-zk-node-event-process-thread]: Shutdown completed (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)