[2025-09-01 01:34:31,295] INFO [ControllerEventThread controllerId=1] Starting (kafka.controller.ControllerEventManager$ControllerEventThread)
[2025-09-01 01:34:31,328] INFO [Controller id=1] 1 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController)
[2025-09-01 01:34:31,329] INFO [Controller id=1] Registering handlers (kafka.controller.KafkaController)
[2025-09-01 01:34:31,332] INFO [Controller id=1] Deleting log dir event notifications (kafka.controller.KafkaController)
[2025-09-01 01:34:31,345] INFO [Controller id=1] Deleting isr change notifications (kafka.controller.KafkaController)
[2025-09-01 01:34:31,348] INFO [Controller id=1] Initializing controller context (kafka.controller.KafkaController)
[2025-09-01 01:34:31,397] INFO [Controller id=1] Initialized broker epochs cache: Map(1 -> 24) (kafka.controller.KafkaController)
[2025-09-01 01:34:31,404] DEBUG [Controller id=1] Register BrokerModifications handler for Set(1) (kafka.controller.KafkaController)
[2025-09-01 01:34:31,409] DEBUG [Channel manager on controller 1]: Controller 1 trying to connect to broker 1 (kafka.controller.ControllerChannelManager)
[2025-09-01 01:34:31,423] INFO [RequestSendThread controllerId=1] Starting (kafka.controller.RequestSendThread)
[2025-09-01 01:34:31,423] INFO [Controller id=1] Currently active brokers in the cluster: Set(1) (kafka.controller.KafkaController)
[2025-09-01 01:34:31,424] INFO [Controller id=1] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
[2025-09-01 01:34:31,424] INFO [Controller id=1] Current list of topics in the cluster: Set() (kafka.controller.KafkaController)
[2025-09-01 01:34:31,424] INFO [Controller id=1] Fetching topic deletions in progress (kafka.controller.KafkaController)
[2025-09-01 01:34:31,428] INFO [Controller id=1] List of topics to be deleted:  (kafka.controller.KafkaController)
[2025-09-01 01:34:31,428] INFO [Controller id=1] List of topics ineligible for deletion:  (kafka.controller.KafkaController)
[2025-09-01 01:34:31,428] INFO [Controller id=1] Initializing topic deletion manager (kafka.controller.KafkaController)
[2025-09-01 01:34:31,429] INFO [Topic Deletion Manager 1] Initializing manager with initial deletions: Set(), initial ineligible deletions: Set() (kafka.controller.TopicDeletionManager)
[2025-09-01 01:34:31,429] INFO [Controller id=1] Sending update metadata request (kafka.controller.KafkaController)
[2025-09-01 01:34:31,437] INFO [ReplicaStateMachine controllerId=1] Initializing replica state (kafka.controller.ZkReplicaStateMachine)
[2025-09-01 01:34:31,437] INFO [ReplicaStateMachine controllerId=1] Triggering online replica state changes (kafka.controller.ZkReplicaStateMachine)
[2025-09-01 01:34:31,447] INFO [ReplicaStateMachine controllerId=1] Triggering offline replica state changes (kafka.controller.ZkReplicaStateMachine)
[2025-09-01 01:34:31,448] DEBUG [ReplicaStateMachine controllerId=1] Started replica state machine with initial state -> Map() (kafka.controller.ZkReplicaStateMachine)
[2025-09-01 01:34:31,451] INFO [PartitionStateMachine controllerId=1] Initializing partition state (kafka.controller.ZkPartitionStateMachine)
[2025-09-01 01:34:31,451] INFO [PartitionStateMachine controllerId=1] Triggering online partition state changes (kafka.controller.ZkPartitionStateMachine)
[2025-09-01 01:34:31,453] DEBUG [PartitionStateMachine controllerId=1] Started partition state machine with initial state -> Map() (kafka.controller.ZkPartitionStateMachine)
[2025-09-01 01:34:31,454] INFO [Controller id=1] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController)
[2025-09-01 01:34:31,459] INFO [Controller id=1] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
[2025-09-01 01:34:31,459] INFO [Controller id=1] Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
[2025-09-01 01:34:31,460] INFO [Controller id=1] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController)
[2025-09-01 01:34:31,460] INFO [Controller id=1] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
[2025-09-01 01:34:31,461] INFO [Controller id=1] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController)
[2025-09-01 01:34:31,463] INFO [RequestSendThread controllerId=1] Controller 1 connected to 10.0.0.50:9092 (id: 1 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
[2025-09-01 01:34:31,551] INFO [Controller id=1] Starting the controller scheduler (kafka.controller.KafkaController)
[2025-09-01 01:34:36,552] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-09-01 01:34:36,553] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-09-01 01:39:36,554] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-09-01 01:39:36,555] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-09-01 01:41:39,307] 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-09-01 01:41:39,308] 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-09-01 01:44:36,555] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-09-01 01:44:36,555] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-09-01 01:44:36,558] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-09-01 01:44:36,559] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-09-01 01:49:36,559] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-09-01 01:49:36,559] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-09-01 01:49:36,560] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-09-01 01:49:36,560] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-09-01 01:54:36,560] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-09-01 01:54:36,560] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-09-01 01:54:36,561] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-09-01 01:54:36,561] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)
[2025-09-01 01:59:36,562] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-09-01 01:59:36,562] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)
[2025-09-01 01:59:36,563] DEBUG [Controller id=1] Topics not in preferred replica for broker 1 Map() (kafka.controller.KafkaController)
[2025-09-01 01:59:36,563] TRACE [Controller id=1] Leader imbalance ratio for broker 1 is 0.0 (kafka.controller.KafkaController)