[2025-11-20 02:02:09,050] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:02:09,051] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:02:09,056] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:02:09,056] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:02:09,057] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:02:09,057] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:02:09,057] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:02:09,057] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:04:07,410] INFO [Controller id=2] New topics: [HashSet(HEALTH_CHECK_TOPIC)], deleted topics: [HashSet()], new partition replica assignment [Set(TopicIdReplicaAssignment(HEALTH_CHECK_TOPIC,Some(3JyziFXnSvWE8mBixXj0mw),HashMap(HEALTH_CHECK_TOPIC-11 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-19 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-15 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-26 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-29 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-25 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-1 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-0 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-7 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-20 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-17 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-21 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-5 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-27 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-6 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-10 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-2 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-12 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-16 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-9 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-13 -> ReplicaAssignment(replicas=2,1,3, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-14 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-24 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-18 -> ReplicaAssignment(replicas=1,3,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-4 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-8 -> ReplicaAssignment(replicas=3,2,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-23 -> ReplicaAssignment(replicas=3,1,2, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-28 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-22 -> ReplicaAssignment(replicas=2,3,1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-3 -> ReplicaAssignment(replicas=1,2,3, addingReplicas=, removingReplicas=))))] (kafka.controller.KafkaController)
[2025-11-20 02:04:07,410] 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-20 02:07:09,057] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:07:09,057] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:07:09,061] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:07:09,061] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:07:09,061] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:07:09,061] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:07:09,063] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:07:09,063] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:12:09,064] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:12:09,064] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:12:09,068] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:12:09,068] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:12:09,068] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:12:09,068] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:12:09,068] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:12:09,068] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:17:09,068] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:17:09,068] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:17:09,096] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:17:09,097] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:17:09,099] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:17:09,099] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:17:09,100] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:17:09,100] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:22:09,100] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:22:09,101] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:22:09,107] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:22:09,107] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:22:09,107] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:22:09,107] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:22:09,107] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:22:09,107] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:27:09,108] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:27:09,108] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:27:09,110] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:27:09,110] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:27:09,111] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:27:09,111] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:27:09,111] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:27:09,111] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:32:09,111] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:32:09,111] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:32:09,114] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:32:09,114] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:32:09,114] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:32:09,114] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:32:09,114] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:32:09,114] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:37:09,114] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:37:09,115] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:37:09,117] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:37:09,117] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:37:09,117] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:37:09,117] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:37:09,117] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:37:09,117] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:42:09,118] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:42:09,118] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:42:09,120] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:42:09,120] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:42:09,120] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:42:09,120] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:42:09,120] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:42:09,120] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:47:09,121] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:47:09,121] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:47:09,123] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:47:09,123] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:47:09,123] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:47:09,123] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:47:09,123] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:47:09,123] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:52:09,123] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:52:09,124] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:52:09,126] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:52:09,126] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:52:09,126] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:52:09,126] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:52:09,127] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:52:09,127] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:57:09,127] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-11-20 02:57:09,127] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-11-20 02:57:09,129] DEBUG [Controller id=2] Topics not in preferred replica for broker 1 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:57:09,129] TRACE [Controller id=2] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:57:09,130] DEBUG [Controller id=2] Topics not in preferred replica for broker 2 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:57:09,130] TRACE [Controller id=2] Leader imbalance ratio for broker 2 is 0.0 (kafka.controller.KafkaController)
[2025-11-20 02:57:09,130] DEBUG [Controller id=2] Topics not in preferred replica for broker 3 HashMap() (kafka.controller.KafkaController)
[2025-11-20 02:57:09,130] TRACE [Controller id=2] Leader imbalance ratio for broker 3 is 0.0 (kafka.controller.KafkaController)