[2026-10-05 01:59:47,684] INFO [ControllerEventThread controllerId=1] Starting (kafka.controller.ControllerEventManager$ControllerEventThread)
[2026-10-05 01:59:47,751] INFO [Controller id=1] 1 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController)
[2026-10-05 01:59:47,759] INFO [Controller id=1] Creating FeatureZNode at path: /feature with contents: FeatureZNode(2,Enabled,Map()) (kafka.controller.KafkaController)
[2026-10-05 01:59:47,876] INFO [Controller id=1] Registering handlers (kafka.controller.KafkaController)
[2026-10-05 01:59:47,885] INFO [Controller id=1] Deleting log dir event notifications (kafka.controller.KafkaController)
[2026-10-05 01:59:47,888] INFO [Controller id=1] Deleting isr change notifications (kafka.controller.KafkaController)
[2026-10-05 01:59:47,893] INFO [Controller id=1] Initializing controller context (kafka.controller.KafkaController)
[2026-10-05 01:59:47,950] INFO [Controller id=1] Initialized broker epochs cache: HashMap(1 -> 25) (kafka.controller.KafkaController)
[2026-10-05 01:59:47,969] DEBUG [Controller id=1] Register BrokerModifications handler for Set(1) (kafka.controller.KafkaController)
[2026-10-05 01:59:47,985] DEBUG [Channel manager on controller 1]: Controller 1 trying to connect to broker 1 (kafka.controller.ControllerChannelManager)
[2026-10-05 01:59:48,014] INFO [RequestSendThread controllerId=1] Starting (kafka.controller.RequestSendThread)
[2026-10-05 01:59:48,016] INFO [Controller id=1] Currently active brokers in the cluster: Set(1) (kafka.controller.KafkaController)
[2026-10-05 01:59:48,016] INFO [Controller id=1] Currently shutting brokers in the cluster: HashSet() (kafka.controller.KafkaController)
[2026-10-05 01:59:48,017] INFO [Controller id=1] Current list of topics in the cluster: HashSet() (kafka.controller.KafkaController)
[2026-10-05 01:59:48,018] INFO [Controller id=1] Fetching topic deletions in progress (kafka.controller.KafkaController)
[2026-10-05 01:59:48,026] INFO [Controller id=1] List of topics to be deleted:  (kafka.controller.KafkaController)
[2026-10-05 01:59:48,026] INFO [Controller id=1] List of topics ineligible for deletion:  (kafka.controller.KafkaController)
[2026-10-05 01:59:48,026] INFO [Controller id=1] Initializing topic deletion manager (kafka.controller.KafkaController)
[2026-10-05 01:59:48,027] INFO [Topic Deletion Manager 1] Initializing manager with initial deletions: Set(), initial ineligible deletions: HashSet() (kafka.controller.TopicDeletionManager)
[2026-10-05 01:59:48,033] INFO [Controller id=1] Sending update metadata request (kafka.controller.KafkaController)
[2026-10-05 01:59:48,073] INFO [ReplicaStateMachine controllerId=1] Initializing replica state (kafka.controller.ZkReplicaStateMachine)
[2026-10-05 01:59:48,074] INFO [ReplicaStateMachine controllerId=1] Triggering online replica state changes (kafka.controller.ZkReplicaStateMachine)
[2026-10-05 01:59:48,112] WARN [RequestSendThread controllerId=1] Controller 1's connection to broker 10.0.0.50:9092 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread)
java.io.IOException: Connection to 10.0.0.50:9092 (id: 1 rack: null) failed.
	at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:252)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:136)
[2026-10-05 01:59:48,112] INFO [ReplicaStateMachine controllerId=1] Triggering offline replica state changes (kafka.controller.ZkReplicaStateMachine)
[2026-10-05 01:59:48,114] DEBUG [ReplicaStateMachine controllerId=1] Started replica state machine with initial state -> HashMap() (kafka.controller.ZkReplicaStateMachine)
[2026-10-05 01:59:48,115] INFO [PartitionStateMachine controllerId=1] Initializing partition state (kafka.controller.ZkPartitionStateMachine)
[2026-10-05 01:59:48,116] INFO [PartitionStateMachine controllerId=1] Triggering online partition state changes (kafka.controller.ZkPartitionStateMachine)
[2026-10-05 01:59:48,124] DEBUG [PartitionStateMachine controllerId=1] Started partition state machine with initial state -> HashMap() (kafka.controller.ZkPartitionStateMachine)
[2026-10-05 01:59:48,125] INFO [Controller id=1] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController)
[2026-10-05 01:59:48,136] INFO [Controller id=1] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
[2026-10-05 01:59:48,136] INFO [Controller id=1] Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
[2026-10-05 01:59:48,136] INFO [Controller id=1] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController)
[2026-10-05 01:59:48,137] INFO [Controller id=1] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
[2026-10-05 01:59:48,138] INFO [Controller id=1] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController)
[2026-10-05 01:59:48,155] INFO [Controller id=1] Starting the controller scheduler (kafka.controller.KafkaController)
[2026-10-05 01:59:48,214] WARN [RequestSendThread controllerId=1] Controller 1's connection to broker 10.0.0.50:9092 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread)
java.io.IOException: Connection to 10.0.0.50:9092 (id: 1 rack: null) failed.
	at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71)
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:299)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:252)
	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:136)
[2026-10-05 01:59:48,323] 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)
[2026-10-05 01:59:53,157] INFO [Controller id=1] Processing automatic preferred replica leader election (kafka.controller.KafkaController)
[2026-10-05 01:59:53,157] TRACE [Controller id=1] Checking need to trigger auto leader balancing (kafka.controller.KafkaController)