[2026-01-01 02:04:21,264] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-11 state from NonExistentPartition to NewPartition with assigned replicas 2,3,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-19 state from NonExistentPartition to NewPartition with assigned replicas 1,3,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-15 state from NonExistentPartition to NewPartition with assigned replicas 3,1,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-26 state from NonExistentPartition to NewPartition with assigned replicas 2,1,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-29 state from NonExistentPartition to NewPartition with assigned replicas 2,3,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-25 state from NonExistentPartition to NewPartition with assigned replicas 1,3,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-1 state from NonExistentPartition to NewPartition with assigned replicas 1,3,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-0 state from NonExistentPartition to NewPartition with assigned replicas 3,2,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-7 state from NonExistentPartition to NewPartition with assigned replicas 1,3,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-20 state from NonExistentPartition to NewPartition with assigned replicas 2,1,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-17 state from NonExistentPartition to NewPartition with assigned replicas 2,3,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-21 state from NonExistentPartition to NewPartition with assigned replicas 3,1,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-5 state from NonExistentPartition to NewPartition with assigned replicas 2,3,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-27 state from NonExistentPartition to NewPartition with assigned replicas 3,1,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-6 state from NonExistentPartition to NewPartition with assigned replicas 3,2,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-10 state from NonExistentPartition to NewPartition with assigned replicas 1,2,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-2 state from NonExistentPartition to NewPartition with assigned replicas 2,1,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-12 state from NonExistentPartition to NewPartition with assigned replicas 3,2,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-16 state from NonExistentPartition to NewPartition with assigned replicas 1,2,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-9 state from NonExistentPartition to NewPartition with assigned replicas 3,1,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-13 state from NonExistentPartition to NewPartition with assigned replicas 1,3,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-14 state from NonExistentPartition to NewPartition with assigned replicas 2,1,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-24 state from NonExistentPartition to NewPartition with assigned replicas 3,2,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-18 state from NonExistentPartition to NewPartition with assigned replicas 3,2,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-4 state from NonExistentPartition to NewPartition with assigned replicas 1,2,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-8 state from NonExistentPartition to NewPartition with assigned replicas 2,1,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-23 state from NonExistentPartition to NewPartition with assigned replicas 2,3,1 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-28 state from NonExistentPartition to NewPartition with assigned replicas 1,2,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-22 state from NonExistentPartition to NewPartition with assigned replicas 1,2,3 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-3 state from NonExistentPartition to NewPartition with assigned replicas 3,1,2 (state.change.logger)
[2026-01-01 02:04:21,265] INFO [Controller id=3 epoch=1] Sending UpdateMetadata request to brokers HashSet() for 0 partitions (state.change.logger)
[2026-01-01 02:04:21,266] INFO [Controller id=3 epoch=1] Sending UpdateMetadata request to brokers HashSet() for 0 partitions (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-11 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-19 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-15 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-26 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-29 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-25 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-1 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-0 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-7 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-20 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-17 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-21 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-5 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-27 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-6 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-10 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-2 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-12 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-16 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-9 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-13 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-14 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-24 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-18 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-4 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-8 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-23 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=2, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-28 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-22 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=1, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1), BrokerState(brokerId=3, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Changed partition HEALTH_CHECK_TOPIC-3 from NewPartition to OnlinePartition with state LeaderAndIsr(leader=3, leaderEpoch=0, isrWithBrokerEpoch=List(BrokerState(brokerId=3, brokerEpoch=-1), BrokerState(brokerId=1, brokerEpoch=-1), BrokerState(brokerId=2, brokerEpoch=-1)), leaderRecoveryState=RECOVERED, partitionEpoch=0) (state.change.logger)
[2026-01-01 02:04:21,312] INFO [Controller id=3 epoch=1] Sending LeaderAndIsr request to broker 1 with 10 become-leader and 20 become-follower partitions (state.change.logger)
[2026-01-01 02:04:21,313] INFO [Controller id=3 epoch=1] Sending LeaderAndIsr request to broker 2 with 10 become-leader and 20 become-follower partitions (state.change.logger)
[2026-01-01 02:04:21,314] INFO [Controller id=3 epoch=1] Sending LeaderAndIsr request to broker 3 with 10 become-leader and 20 become-follower partitions (state.change.logger)
[2026-01-01 02:04:21,314] INFO [Controller id=3 epoch=1] Sending UpdateMetadata request to brokers HashSet(1, 2, 3) for 30 partitions (state.change.logger)
[2026-01-01 02:04:21,314] INFO [Broker id=3] Handling LeaderAndIsr request correlationId 8 from controller 3 for 30 partitions (state.change.logger)
[2026-01-01 02:04:21,316] INFO [Broker id=3] Stopped fetchers as part of LeaderAndIsr request correlationId 8 from controller 3 epoch 1 as part of the become-leader transition for 10 partitions (state.change.logger)
[2026-01-01 02:04:21,317] INFO [Controller id=3 epoch=1] Sending UpdateMetadata request to brokers HashSet() for 0 partitions (state.change.logger)
[2026-01-01 02:04:21,347] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-12 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,2,1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,356] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-15 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,1,2], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,365] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-0 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,2,1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,372] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-3 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,1,2], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,382] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-18 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,2,1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,391] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-21 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,1,2], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,399] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-6 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,2,1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,408] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-9 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,1,2], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,422] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-24 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,2,1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,434] INFO [Broker id=3] Leader HEALTH_CHECK_TOPIC-27 with topic id Some(X3OY1-TlTGWVSdZ8t5RClA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [3,1,2], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. (state.change.logger)
[2026-01-01 02:04:21,443] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-29 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,446] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-14 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,451] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-1 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,454] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-16 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,458] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-5 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,461] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-20 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,464] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-7 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,468] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-22 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,471] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-11 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,473] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-26 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,475] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-13 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,477] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-28 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,479] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-17 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,482] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-19 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,485] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-2 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,487] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-4 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,491] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-23 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,492] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-25 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,497] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-8 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader Some(2) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,506] INFO [Broker id=3] Follower HEALTH_CHECK_TOPIC-10 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader Some(1) and previous leader epoch was 0. (state.change.logger)
[2026-01-01 02:04:21,506] INFO [Broker id=3] Stopped fetchers as part of become-follower request from controller 3 epoch 1 with correlation id 8 for 20 partitions (state.change.logger)
[2026-01-01 02:04:21,528] INFO [Broker id=3] Finished LeaderAndIsr request in 214ms correlationId 8 from controller 3 for 30 partitions (state.change.logger)
[2026-01-01 02:04:21,530] INFO [Broker id=3] Add 30 partitions and deleted 0 partitions from metadata cache in response to UpdateMetadata request sent by controller 3 epoch 1 with correlation id 9 (state.change.logger)