[2025-02-17 01:01:17,590] INFO [Controller id=2] New topics: [Set(HEALTH_CHECK_TOPIC)], deleted topics: [Set()], new partition replica assignment [Map(HEALTH_CHECK_TOPIC-11 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-19 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-27 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-6 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-10 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-2 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-12 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-16 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-15 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-26 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-9 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-13 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-29 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-25 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-1 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-14 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-24 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-18 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-4 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-8 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-0 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-7 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-20 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-23 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-28 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-22 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-3 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-17 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-21 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-5 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=))] (kafka.controller.KafkaController)
[2025-02-17 01:01:17,590] INFO [Controller id=2] New partition creation callback for HEALTH_CHECK_TOPIC-11,HEALTH_CHECK_TOPIC-19,HEALTH_CHECK_TOPIC-27,HEALTH_CHECK_TOPIC-6,HEALTH_CHECK_TOPIC-10,HEALTH_CHECK_TOPIC-2,HEALTH_CHECK_TOPIC-12,HEALTH_CHECK_TOPIC-16,HEALTH_CHECK_TOPIC-15,HEALTH_CHECK_TOPIC-26,HEALTH_CHECK_TOPIC-9,HEALTH_CHECK_TOPIC-13,HEALTH_CHECK_TOPIC-29,HEALTH_CHECK_TOPIC-25,HEALTH_CHECK_TOPIC-1,HEALTH_CHECK_TOPIC-14,HEALTH_CHECK_TOPIC-24,HEALTH_CHECK_TOPIC-18,HEALTH_CHECK_TOPIC-4,HEALTH_CHECK_TOPIC-8,HEALTH_CHECK_TOPIC-0,HEALTH_CHECK_TOPIC-7,HEALTH_CHECK_TOPIC-20,HEALTH_CHECK_TOPIC-23,HEALTH_CHECK_TOPIC-28,HEALTH_CHECK_TOPIC-22,HEALTH_CHECK_TOPIC-3,HEALTH_CHECK_TOPIC-17,HEALTH_CHECK_TOPIC-21,HEALTH_CHECK_TOPIC-5 (kafka.controller.KafkaController)
[2025-02-17 01:04:20,546] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:04:20,546] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:04:20,549] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:04:20,549] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:04:20,549] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:04:20,549] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:04:20,549] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:04:20,549] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:09:20,550] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:09:20,550] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:09:20,552] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:09:20,552] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:09:20,553] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:09:20,553] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:09:20,553] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:09:20,553] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:14:20,553] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:14:20,553] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:14:20,555] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:14:20,555] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:14:20,555] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:14:20,555] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:14:20,556] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:14:20,556] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:19:20,556] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:19:20,556] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:19:20,558] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:19:20,558] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:19:20,558] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:19:20,558] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:19:20,559] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:19:20,559] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:24:20,559] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:24:20,559] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:24:20,561] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:24:20,561] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:24:20,561] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:24:20,561] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:24:20,561] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:24:20,561] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:29:20,562] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:29:20,562] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:29:20,565] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:29:20,565] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:29:20,565] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:29:20,565] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:29:20,566] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:29:20,566] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:34:20,566] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:34:20,566] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:34:20,568] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:34:20,568] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:34:20,568] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:34:20,568] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:34:20,568] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:34:20,568] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:39:20,568] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:39:20,568] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:39:20,570] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:39:20,570] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:39:20,570] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:39:20,570] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:39:20,570] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:39:20,570] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:44:20,570] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:44:20,571] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:44:20,572] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:44:20,572] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:44:20,572] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:44:20,572] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:44:20,573] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:44:20,573] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:49:20,573] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-02-17 01:49:20,573] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-02-17 01:49:20,575] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 Map() (kafka.controller.KafkaController)
[2025-02-17 01:49:20,575] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:49:20,575] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-02-17 01:49:20,575] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:49:20,575] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 Map() (kafka.controller.KafkaController)
[2025-02-17 01:49:20,575] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-02-17 01:53:24,107] INFO [Controller id=2] Shutting down broker 3 (kafka.controller.KafkaController)
[2025-02-17 01:53:24,122] DEBUG [Controller id=2] All shutting down brokers: 3 (kafka.controller.KafkaController)
[2025-02-17 01:53:24,128] DEBUG [Controller id=2] Live brokers: 2,1 (kafka.controller.KafkaController)
[2025-02-17 01:54:18,018] INFO [ControllerEventThread controllerId=2] Starting (kafka.controller.ControllerEventManager$ControllerEventThread)
[2025-02-17 01:54:18,053] DEBUG [Controller id=2] Broker 1 has been elected as the controller, so stopping the election process. (kafka.controller.KafkaController)
[2025-02-17 01:56:41,576] INFO [ControllerEventThread controllerId=2] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread)
[2025-02-17 01:56:41,577] INFO [ControllerEventThread controllerId=2] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread)
[2025-02-17 01:56:41,577] INFO [ControllerEventThread controllerId=2] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread)
[2025-02-17 01:56:41,578] DEBUG [Controller id=2] Resigning (kafka.controller.KafkaController)
[2025-02-17 01:56:41,578] DEBUG [Controller id=2] Unregister BrokerModifications handler for Set() (kafka.controller.KafkaController)
[2025-02-17 01:56:41,580] INFO [PartitionStateMachine controllerId=2] Stopped partition state machine (kafka.controller.ZkPartitionStateMachine)
[2025-02-17 01:56:41,581] INFO [ReplicaStateMachine controllerId=2] Stopped replica state machine (kafka.controller.ZkReplicaStateMachine)
[2025-02-17 01:56:41,581] INFO [Controller id=2] Resigned (kafka.controller.KafkaController)
[2025-02-17 01:58:40,533] INFO [ControllerEventThread controllerId=2] Starting (kafka.controller.ControllerEventManager$ControllerEventThread)
[2025-02-17 01:58:40,574] DEBUG [Controller id=2] Broker 3 has been elected as the controller, so stopping the election process. (kafka.controller.KafkaController)