[2018-05-28 00:39:46,195] TRACE [Broker id=1003] Cached leader info PartitionState(controllerEpoch=1, leader=1001, leaderEpoch=5, isr=[1001, 1002, 1003], zkVersion=8, replicas=[1003, 1001, 1002], offlineReplicas=[]) for partition steve-0 in response to UpdateMetadata request sent by controller 1001 epoch 1 with correlation id 6 (state.change.logger)
[2018-05-28 00:39:46,195] TRACE [Broker id=1003] Cached leader info PartitionState(controllerEpoch=1, leader=1001, leaderEpoch=3, isr=[1001, 1002, 1003], zkVersion=6, replicas=[1001, 1002, 1003], offlineReplicas=[]) for partition apple-7 in response to UpdateMetadata request sent by controller 1001 epoch 1 with correlation id 6 (state.change.logger)
[2018-05-28 00:43:20,093] TRACE [Broker id=1003] Received LeaderAndIsr request PartitionState(controllerEpoch=1, leader=1003, leaderEpoch=6, isr=1001,1002,1003, zkVersion=9, replicas=1003,1001,1002, isNew=false) correlation id 7 from controller 1001 epoch 1 for partition apple-0 (state.change.logger)
[2018-05-28 00:43:20,093] TRACE [Broker id=1003] Handling LeaderAndIsr request correlationId 7 from controller 1001 epoch 1 starting the become-leader transition for partition apple-0 (state.change.logger)
[2018-05-28 00:43:20,193] INFO [ReplicaFetcherManager on broker 1003] Removed fetcher for partitions apple-0 (kafka.server.ReplicaFetcherManager)
[2018-05-28 00:43:20,193] INFO [Partition apple-0 broker=1003] apple-0 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition)
[2018-05-28 00:43:20,193] TRACE [Broker id=1003] Stopped fetchers as part of become-leader request from controller 1001 epoch 1 with correlation id 7 for partition apple-0 (last update controller epoch 1) (state.change.logger)
[2018-05-28 00:43:20,194] TRACE [Broker id=1003] Completed LeaderAndIsr request correlationId 7 from controller 1001 epoch 1 for the become-leader transition for partition apple-0 (state.change.logger)
[2018-05-28 00:43:20,993] ERROR [ReplicaFetcher replicaId=1003, leaderId=1001, fetcherId=0] Error for partition apple-6 to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2018-05-28 00:43:20,993] ERROR [ReplicaFetcher replicaId=1003, leaderId=1001, fetcherId=0] Error for partition steve-0 to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2018-05-28 00:43:20,993] TRACE [Broker id=1003] Cached leader info PartitionState(controllerEpoch=1, leader=1003, leaderEpoch=6, isr=[1001, 1002, 1003], zkVersion=9, replicas=[1003, 1001, 1002], offlineReplicas=[]) for partition apple-0 in response to UpdateMetadata request sent by controller 1001 epoch 1 with correlation id 8 (state.change.logger)
[2018-05-28 00:43:20,993] ERROR [ReplicaFetcher replicaId=1003, leaderId=1001, fetcherId=0] Error for partition mango2-0 to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2018-05-28 00:43:21,268] ERROR [ReplicaFetcher replicaId=1003, leaderId=1001, fetcherId=0] Error for partition apple-12 to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2018-05-28 00:43:21,268] ERROR [ReplicaFetcher replicaId=1003, leaderId=1001, fetcherId=0] Error for partition mango2-6 to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2018-05-28 00:43:21,268] ERROR [ReplicaFetcher replicaId=1003, leaderId=1001, fetcherId=0] Error for partition mango2-12 to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2018-05-28 00:43:21,298] TRACE [Broker id=1003] Received LeaderAndIsr request PartitionState(controllerEpoch=1, leader=1003, leaderEpoch=6, isr=1001,1003, zkVersion=9, replicas=1003,1001, isNew=false) correlation id 9 from controller 1001 epoch 1 for partition mango2-0 (state.change.logger)
[2018-05-28 00:43:21,298] TRACE [Broker id=1003] Handling LeaderAndIsr request correlationId 9 from controller 1001 epoch 1 starting the become-leader transition for partition mango2-0 (state.change.logger)
[2018-05-28 00:43:21,298] INFO [ReplicaFetcherManager on broker 1003] Removed fetcher for partitions mango2-0 (kafka.server.ReplicaFetcherManager)
[2018-05-28 00:43:21,298] INFO [Partition mango2-0 broker=1003] mango2-0 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition)
[2018-05-28 00:43:21,298] TRACE [Broker id=1003] Stopped fetchers as part of become-leader request from controller 1001 epoch 1 with correlation id 9 for partition mango2-0 (last update controller epoch 1) (state.change.logger)