[2025-04-14 02:03:41,379] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:03:41,381] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:03:41,396] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:03:41,397] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController) [2025-04-14 02:06:17,076] INFO [Controller id=1] New topics: [Set(HEALTH_CHECK_TOPIC)], deleted topics: [Set()], new partition replica assignment [Map(HEALTH_CHECK_TOPIC-11 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-19 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-27 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-6 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-10 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-2 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-12 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-16 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-15 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-26 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-9 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-13 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-29 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-25 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-1 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-14 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-24 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-18 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-4 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-8 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-0 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-7 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-20 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-23 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-28 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-22 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-3 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-17 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-21 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=), HEALTH_CHECK_TOPIC-5 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=))] (kafka.controller.KafkaController) [2025-04-14 02:06:17,076] INFO [Controller id=1] 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-04-14 02:08:41,398] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:08:41,398] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:08:41,410] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:08:41,410] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController) [2025-04-14 02:13:41,411] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:13:41,411] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:13:41,414] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:13:41,414] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController) [2025-04-14 02:18:41,414] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:18:41,414] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:18:41,421] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:18:41,421] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController) [2025-04-14 02:23:41,421] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:23:41,422] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:23:41,424] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:23:41,424] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController) [2025-04-14 02:28:41,425] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:28:41,425] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:28:41,434] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:28:41,434] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController) [2025-04-14 02:33:41,435] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:33:41,435] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:33:41,437] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:33:41,437] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController) [2025-04-14 02:38:41,437] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:38:41,438] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:38:41,444] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:38:41,444] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController) [2025-04-14 02:43:41,444] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:43:41,444] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:43:41,446] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:43:41,446] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController) [2025-04-14 02:48:41,446] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController) [2025-04-14 02:48:41,446] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController) [2025-04-14 02:48:41,449] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController) [2025-04-14 02:48:41,449] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)