[2025-11-10 02:03:35,689] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:03:35,690] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:03:35,696] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:03:35,696] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:03:35,697] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:03:35,697] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:03:35,697] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:03:35,697] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:05:35,102] INFO [Controller id=2] New topics: [HashSet(HEALTH_CHECK_TOPIC)], deleted topics: [HashSet()], new partition replica assignment [Set(TopicIdReplicaAssignment(HEALTH_CHECK_TOPIC,Some(PMkr2G1nQnyjubyOoDNujg),HashMap(HEALTH_CHECK_TOPIC-11 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-19 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-15 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-26 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-29 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-25 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-1 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-0 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-7 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-20 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-17 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-21 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-5 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-27 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-6 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-10 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-2 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-12 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-16 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-9 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-13 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-14 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-24 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-18 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-4 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-8 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-23 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-28 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-22 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-3 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=))))] (kafka.controller.KafkaController)
[2025-11-10 02:05:35,102] INFO [Controller id=2] New partition creation callback for HEALTH_CHECK_TOPIC-11,HEALTH_CHECK_TOPIC-19,HEALTH_CHECK_TOPIC-15,HEALTH_CHECK_TOPIC-26,HEALTH_CHECK_TOPIC-29,HEALTH_CHECK_TOPIC-25,HEALTH_CHECK_TOPIC-1,HEALTH_CHECK_TOPIC-0,HEALTH_CHECK_TOPIC-7,HEALTH_CHECK_TOPIC-20,HEALTH_CHECK_TOPIC-17,HEALTH_CHECK_TOPIC-21,HEALTH_CHECK_TOPIC-5,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-9,HEALTH_CHECK_TOPIC-13,HEALTH_CHECK_TOPIC-14,HEALTH_CHECK_TOPIC-24,HEALTH_CHECK_TOPIC-18,HEALTH_CHECK_TOPIC-4,HEALTH_CHECK_TOPIC-8,HEALTH_CHECK_TOPIC-23,HEALTH_CHECK_TOPIC-28,HEALTH_CHECK_TOPIC-22,HEALTH_CHECK_TOPIC-3 (kafka.controller.KafkaController)
[2025-11-10 02:08:35,697] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:08:35,697] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:08:35,702] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:08:35,703] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:08:35,703] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:08:35,703] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:08:35,703] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:08:35,703] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:13:35,703] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:13:35,703] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:13:35,707] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:13:35,707] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:13:35,707] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:13:35,707] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:13:35,708] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:13:35,708] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:18:35,708] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:18:35,708] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:18:35,710] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:18:35,710] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:18:35,711] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:18:35,711] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:18:35,711] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:18:35,711] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:23:35,711] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:23:35,711] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:23:35,714] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:23:35,714] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:23:35,714] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:23:35,714] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:23:35,714] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:23:35,714] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:28:35,715] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:28:35,715] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:28:35,717] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:28:35,717] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:28:35,717] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:28:35,717] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:28:35,718] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:28:35,718] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:33:35,718] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:33:35,718] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:33:35,720] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:33:35,720] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:33:35,720] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:33:35,720] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:33:35,720] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:33:35,721] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:38:35,721] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:38:35,721] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:38:35,723] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:38:35,723] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:38:35,723] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:38:35,723] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:38:35,723] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:38:35,723] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:43:35,723] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:43:35,723] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:43:35,725] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:43:35,725] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:43:35,725] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:43:35,725] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:43:35,725] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:43:35,725] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:48:35,726] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:48:35,726] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:48:35,728] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:48:35,728] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:48:35,728] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:48:35,728] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:48:35,728] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:48:35,728] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:53:35,728] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:53:35,728] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:53:35,731] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:53:35,731] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:53:35,731] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:53:35,731] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:53:35,731] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:53:35,731] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:58:35,731] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-10 02:58:35,732] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-10 02:58:35,734] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:58:35,734] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:58:35,734] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:58:35,735] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-10 02:58:35,735] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-10 02:58:35,735] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)