[2025-09-01 01:59:09,898] INFO [ControllerEventThread controllerId=2] Starting (kafka.controller.ControllerEventManager$ControllerEventThread)
[2025-09-01 01:59:09,932] INFO [Controller id=2] 2 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController)
[2025-09-01 01:59:09,933] INFO [Controller id=2] Registering handlers (kafka.controller.KafkaController)
[2025-09-01 01:59:09,938] INFO [Controller id=2] Deleting log dir event notifications (kafka.controller.KafkaController)
[2025-09-01 01:59:09,945] INFO [Controller id=2] Deleting isr change notifications (kafka.controller.KafkaController)
[2025-09-01 01:59:09,948] INFO [Controller id=2] Initializing controller context (kafka.controller.KafkaController)
[2025-09-01 01:59:10,027] INFO [Controller id=2] Initialized broker epochs cache: Map(2 -> 4294967614) (kafka.controller.KafkaController)
[2025-09-01 01:59:10,038] DEBUG [Controller id=2] Register BrokerModifications handler for Set(2) (kafka.controller.KafkaController)
[2025-09-01 01:59:10,050] DEBUG [Channel manager on controller 2]: Controller 2 trying to connect to broker 2 (kafka.controller.ControllerChannelManager)
[2025-09-01 01:59:10,063] INFO [Controller id=2] Currently active brokers in the cluster: Set(2) (kafka.controller.KafkaController)
[2025-09-01 01:59:10,064] INFO [Controller id=2] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
[2025-09-01 01:59:10,064] INFO [Controller id=2] Current list of topics in the cluster: Set() (kafka.controller.KafkaController)
[2025-09-01 01:59:10,065] INFO [Controller id=2] Fetching topic deletions in progress (kafka.controller.KafkaController)
[2025-09-01 01:59:10,066] INFO [RequestSendThread controllerId=2] Starting (kafka.controller.RequestSendThread)
[2025-09-01 01:59:10,072] INFO [Controller id=2] List of topics to be deleted:  (kafka.controller.KafkaController)
[2025-09-01 01:59:10,072] INFO [Controller id=2] List of topics ineligible for deletion:  (kafka.controller.KafkaController)
[2025-09-01 01:59:10,073] INFO [Controller id=2] Initializing topic deletion manager (kafka.controller.KafkaController)
[2025-09-01 01:59:10,073] INFO [Topic Deletion Manager 2] Initializing manager with initial deletions: Set(), initial ineligible deletions: Set() (kafka.controller.TopicDeletionManager)
[2025-09-01 01:59:10,073] INFO [Controller id=2] Sending update metadata request (kafka.controller.KafkaController)
[2025-09-01 01:59:10,113] INFO [ReplicaStateMachine controllerId=2] Initializing replica state (kafka.controller.ZkReplicaStateMachine)
[2025-09-01 01:59:10,114] INFO [ReplicaStateMachine controllerId=2] Triggering online replica state changes (kafka.controller.ZkReplicaStateMachine)
[2025-09-01 01:59:10,119] INFO [ReplicaStateMachine controllerId=2] Triggering offline replica state changes (kafka.controller.ZkReplicaStateMachine)
[2025-09-01 01:59:10,119] DEBUG [ReplicaStateMachine controllerId=2] Started replica state machine with initial state -> Map() (kafka.controller.ZkReplicaStateMachine)
[2025-09-01 01:59:10,120] INFO [PartitionStateMachine controllerId=2] Initializing partition state (kafka.controller.ZkPartitionStateMachine)
[2025-09-01 01:59:10,121] INFO [PartitionStateMachine controllerId=2] Triggering online partition state changes (kafka.controller.ZkPartitionStateMachine)
[2025-09-01 01:59:10,124] INFO [RequestSendThread controllerId=2] Controller 2 connected to 10.0.0.38:9092 (id: 2 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
[2025-09-01 01:59:10,124] DEBUG [PartitionStateMachine controllerId=2] Started partition state machine with initial state -> Map() (kafka.controller.ZkPartitionStateMachine)
[2025-09-01 01:59:10,124] INFO [Controller id=2] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController)
[2025-09-01 01:59:10,187] INFO [Controller id=2] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
[2025-09-01 01:59:10,187] INFO [Controller id=2] Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
[2025-09-01 01:59:10,187] INFO [Controller id=2] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController)
[2025-09-01 01:59:10,188] INFO [Controller id=2] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
[2025-09-01 01:59:10,199] INFO [Controller id=2] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController)
[2025-09-01 01:59:10,225] INFO [Controller id=2] Starting the controller scheduler (kafka.controller.KafkaController)
[2025-09-01 01:59:10,250] INFO [Controller id=2] Newly added brokers: 3, deleted brokers: , bounced brokers: , all live brokers: 2,3 (kafka.controller.KafkaController)
[2025-09-01 01:59:10,251] DEBUG [Channel manager on controller 2]: Controller 2 trying to connect to broker 3 (kafka.controller.ControllerChannelManager)
[2025-09-01 01:59:10,257] INFO [RequestSendThread controllerId=2] Starting (kafka.controller.RequestSendThread)
[2025-09-01 01:59:10,258] INFO [Controller id=2] New broker startup callback for 3 (kafka.controller.KafkaController)
[2025-09-01 01:59:10,260] INFO [RequestSendThread controllerId=2] Controller 2 connected to 10.0.0.131:9092 (id: 3 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
[2025-09-01 01:59:10,263] DEBUG [Controller id=2] Register BrokerModifications handler for Vector(3) (kafka.controller.KafkaController)
[2025-09-01 01:59:10,271] INFO [Controller id=2] Updated broker epochs cache: Map(2 -> 4294967614, 3 -> 4294967618) (kafka.controller.KafkaController)
[2025-09-01 01:59:11,357] INFO [Controller id=2] Newly added brokers: 1, deleted brokers: , bounced brokers: , all live brokers: 1,2,3 (kafka.controller.KafkaController)
[2025-09-01 01:59:11,357] DEBUG [Channel manager on controller 2]: Controller 2 trying to connect to broker 1 (kafka.controller.ControllerChannelManager)
[2025-09-01 01:59:11,364] INFO [RequestSendThread controllerId=2] Starting (kafka.controller.RequestSendThread)
[2025-09-01 01:59:11,364] INFO [Controller id=2] New broker startup callback for 1 (kafka.controller.KafkaController)
[2025-09-01 01:59:11,368] DEBUG [Controller id=2] Register BrokerModifications handler for Vector(1) (kafka.controller.KafkaController)
[2025-09-01 01:59:11,369] INFO [RequestSendThread controllerId=2] Controller 2 connected to 10.0.0.249:9092 (id: 1 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
[2025-09-01 01:59:11,371] INFO [Controller id=2] Updated broker epochs cache: Map(2 -> 4294967614, 1 -> 4294967637, 3 -> 4294967618) (kafka.controller.KafkaController)
[2025-09-01 01:59:15,227] INFO [Controller id=2] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2025-09-01 01:59:15,227] TRACE [Controller id=2] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)