Re: Seeking help on Repetitive "Error in Partition" in Kafka ...

[Abhit Kalsotra]

Any pointers please......

On Dec 4, 2017 16:43, "Abhit Kalsotra" <abhit...@gmail.com> wrote:

Dear *

I am using librdkafka 0.9.2 and kafka 0.10.2.0 , did not update the
librdkafka from 0.9.2 because it had been running satisfactory,in my stack.

My Kafka Setup:

*Setup: 3 ZK instances running on 3 different Windows Servers, 7 kafka
Broker nodes running on single windows machine with different disk for logs
directory.... *

*It has two Kafka Topics with partition size 50 , and replication factor of
3.*

My partition logic selection: like for each message (its unique ID % 50) ,
and then calling Kafka producer API to route a specific message to a
particular topic partition .

But of-late there has been a unique case that's cropping out in Kafka
broker nodes, its been running fine then one day one of my broker nodes
started failing and on server.log , i have insane recursive such log
statements

[2017-12-02 02:47:39,399] ERROR [KafkaApi-1] Error when handling
request 
{controller_id=0,controller_epoch=1,partition_states=[{topic=__consumer_offsets,partition=49,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[3,5,6]},{topic=__consumer_offsets,partition=8,controller_epoch=1,leader=6,leader_epoch=1,isr=[6],zk_version=1,replicas=[4,6,0]},{topic=LIVETOPIC,partition=12,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[4,3,5]},{topic=LIVETOPIC,partition=1,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[0,5,6]},{topic=LIVETOPICOLD,partition=10,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[0,4,5]},{topic=LIVETOPICOLD,partition=21,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[4,3,5]},{topic=__consumer_offsets,partition=35,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[3,2,4]},{topic=__consumer_offsets,partition=46,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[0,1,2]},{topic=LIVETOPICOLD,partition=48,controller_epoch=1,leader=6,leader_epoch=1,isr=[6],zk_version=1,replicas=[3,6,0]},{topic=LIVETOPIC,partition=39,controller_epoch=1,leader=1,leader_epoch=1,isr=[1],zk_version=1,replicas=[3,0,1]},{topic=LIVETOPICOLD,partition=7,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[4,1,2]},{topic=__consumer_offsets,partition=43,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[4,5,6]},{topic=__consumer_offsets,partition=32,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[0,5,6]},{topic=__consumer_offsets,partition=21,controller_epoch=1,leader=1,leader_epoch=1,isr=[1],zk_version=1,replicas=[3,0,1]},{topic=LIVETOPIC,partition=36,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[0,4,5]},{topic=LIVETOPIC,partition=47,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[4,2,3]},{topic=LIVETOPIC,partition=25,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[3,5,6]},{topic=LIVETOPICOLD,partition=34,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[3,4,5]},{topic=LIVETOPICOLD,partition=42,controller_epoch=1,leader=1,leader_epoch=1,isr=[1],zk_version=1,replicas=[4,0,1]},{topic=LIVETOPIC,partition=22,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[0,2,3]},{topic=LIVETOPIC,partition=33,controller_epoch=1,leader=1,leader_epoch=1,isr=[1],zk_version=1,replicas=[4,0,1]},{topic=LIVETOPICOLD,partition=31,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[0,1,2]},{topic=__consumer_offsets,partition=29,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[4,2,3]},{topic=LIVETOPICOLD,partition=20,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[3,1,2]},{topic=__consumer_offsets,partition=7,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[3,5,6]},{topic=LIVETOPIC,partition=11,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[3,2,4]},{topic=LIVETOPIC,partition=8,controller_epoch=1,leader=6,leader_epoch=1,isr=[6,1],zk_version=1,replicas=[0,6,1]},{topic=LIVETOPIC,partition=19,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[4,5,6]},{topic=LIVETOPICOLD,partition=17,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[0,5,6]},{topic=LIVETOPICOLD,partition=28,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[4,5,6]},{topic=LIVETOPICOLD,partition=6,controller_epoch=1,leader=6,leader_epoch=1,isr=[6],zk_version=1,replicas=[3,6,0]},{topic=__consumer_offsets,partition=15,controller_epoch=1,leader=1,leader_epoch=1,isr=[1],zk_version=1,replicas=[4,0,1]},{topic=__consumer_offsets,partition=4,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[0,1,2]},{topic=__consumer_offsets,partition=42,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[3,4,5]},{topic=LIVETOPIC,partition=46,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[3,1,2]},{topic=LIVETOPICOLD,partition=14,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[4,2,3]},{topic=__consumer_offsets,partition=1,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[4,5,6]},{topic=LIVETOPIC,partition=5,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[4,2,3]},{topic=LIVETOPIC,partition=43,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[0,5,6]},{topic=LIVETOPIC,partition=32,controller_epoch=1,leader=6,leader_epoch=1,isr=[6],zk_version=1,replicas=[3,6,0]},{topic=LIVETOPICOLD,partition=41,controller_epoch=1,leader=5,leader_epoch=1,isr=[5,6],zk_version=1,replicas=[3,5,6]},{topic=__consumer_offsets,partition=28,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[3,1,2]},{topic=__consumer_offsets,partition=39,controller_epoch=1,leader=6,leader_epoch=1,isr=[6,1],zk_version=1,replicas=[0,6,1]},{topic=LIVETOPICOLD,partition=0,controller_epoch=1,leader=1,leader_epoch=1,isr=[1],zk_version=1,replicas=[4,0,1]},{topic=LIVETOPICOLD,partition=27,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[3,2,4]},{topic=__consumer_offsets,partition=36,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[4,3,5]},{topic=LIVETOPIC,partition=40,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[4,1,2]},{topic=__consumer_offsets,partition=25,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[0,4,5]},{topic=LIVETOPIC,partition=18,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[3,4,5]},{topic=LIVETOPICOLD,partition=49,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[4,1,2]},{topic=__consumer_offsets,partition=14,controller_epoch=1,leader=6,leader_epoch=1,isr=[6],zk_version=1,replicas=[3,6,0]},{topic=LIVETOPICOLD,partition=38,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[0,2,3]},{topic=__consumer_offsets,partition=11,controller_epoch=1,leader=2,leader_epoch=1,isr=[2],zk_version=1,replicas=[0,2,3]},{topic=__consumer_offsets,partition=22,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[4,1,2]},{topic=__consumer_offsets,partition=0,controller_epoch=1,leader=5,leader_epoch=1,isr=[5],zk_version=1,replicas=[3,4,5]},{topic=LIVETOPICOLD,partition=24,controller_epoch=1,leader=6,leader_epoch=1,isr=[6,1],zk_version=1,replicas=[0,6,1]},{topic=LIVETOPICOLD,partition=35,controller_epoch=1,leader=6,leader_epoch=1,isr=[6],zk_version=1,replicas=[4,6,0]},{topic=LIVETOPICOLD,partition=13,controller_epoch=1,leader=1,leader_epoch=1,isr=[1],zk_version=1,replicas=[3,0,1]},{topic=LIVETOPIC,partition=15,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[0,1,2]},{topic=LIVETOPIC,partition=26,controller_epoch=1,leader=6,leader_epoch=1,isr=[6],zk_version=1,replicas=[4,6,0]},{topic=LIVETOPIC,partition=4,controller_epoch=1,leader=1,leader_epoch=1,isr=[1,2],zk_version=1,replicas=[3,1,2]}],live_brokers=[{id=1,end_points=[{port=9094,host=10.83.24.37,security_protocol_type=0}],rack=null},{id=2,end_points=[{port=9095,host=10.83.24.37,security_protocol_type=0}],rack=null},{id=5,end_points=[{port=9098,host=10.83.24.37,security_protocol_type=0}],rack=null},{id=6,end_points=[{port=9099,host=10.83.24.37,security_protocol_type=0}],rack=null}]}
(kafka.server.KafkaApis)
org.apache.kafka.common.errors.ControllerMovedException: Broker 1
received update metadata request with correlation id 13 from an old
controller 0 with epoch 1. Latest known controller epoch is 2


And the entire server.log has these logs

[2017-12-02 02:56:40,058] ERROR [ReplicaFetcherThread-0-1], Error for
partition [__consumer_offsets,9] to broker
1:org.apache.kafka.common.errors.NotLeaderForPartitionException: This
server is not the leader for that topic-partition.
(kafka.server.ReplicaFetcherThread)
[2017-12-02 02:56:40,058] INFO Partition [LIVETOPICOLD,36] on broker
1: Expanding ISR for partition [LIVETOPICOLD,36] from 1,5 to 1,5,0
(kafka.cluster.Partition)
[2017-12-02 02:56:40,089] INFO Partition [LIVETOPICOLD,36] on broker
1: Cached zkVersion [2] not equal to that in zookeeper, skip updating
ISR (kafka.cluster.Partition)
[2017-12-02 02:56:40,089] INFO Partition [LIVETOPICOLD,36] on broker
1: Expanding ISR for partition [LIVETOPICOLD,36] from 1,5 to 1,5,0
(kafka.cluster.Partition)
[2017-12-02 02:56:40,120] INFO Partition [LIVETOPICOLD,36] on broker
1: Cached zkVersion [2] not equal to that in zookeeper, skip updating
ISR (kafka.cluster.Partition)


At the same time the controller.log

[2017-12-02 02:47:36,102] INFO [SessionExpirationListener on 3], ZK
expired; shut down all controller components and try to re-elect
(kafka.controller.KafkaController$SessionExpirationListener)
[2017-12-02 02:47:36,102] DEBUG [Controller 3]: Controller resigning,
broker id 3 (kafka.controller.KafkaController)
[2017-12-02 02:47:36,102] DEBUG [Controller 3]: De-registering
IsrChangeNotificationListener (kafka.controller.KafkaController)
[2017-12-02 02:47:36,102] INFO [Controller-0-to-broker-4-send-thread],
Stopped  (kafka.controller.RequestSendThread)
[2017-12-02 02:47:36,102] INFO [Controller-0-to-broker-4-send-thread],
Shutdown completed (kafka.controller.RequestSendThread)
[2017-12-02 02:47:36,102] DEBUG [Channel manager on controller 1]:
Controller 1 trying to connect to broker 1
(kafka.controller.ControllerChannelManager)
[2017-12-02 02:47:36,102] INFO [Controller 0]: Broker failure callback
for 0,3,4 (kafka.controller.KafkaController)
[2017-12-02 02:47:36,102] INFO [Partition state machine on Controller
3]: Stopped partition state machine
(kafka.controller.PartitionStateMachine)
[2017-12-02 02:47:36,102] INFO [Replica state machine on controller
3]: Stopped replica state machine
(kafka.controller.ReplicaStateMachine)
[2017-12-02 02:47:36,102] INFO [Controller 0]: Removed ArrayBuffer()
from list of shutting down brokers. (kafka.controller.KafkaController)
[2017-12-02 02:47:36,102] INFO [Controller 3]: Broker 3 resigned as
the controller (kafka.controller.KafkaController)
[2017-12-02 02:47:36,102] INFO [Partition state machine on Controller
0]: Invoking state change to OfflinePartition for partitions
[LIVETOPIC,11],[LIVETOPIC,46],[__consumer_offsets,29],[LIVETOPICOLD,0],[LIVETOPICOLD,38],[__consumer_offsets,39],[__consumer_offsets,14],[LIVETOPICOLD,35],[__consumer_offsets,18],[LIVETOPIC,43],[__consumer_offsets,0],[LIVETOPIC,32],[LIVETOPICOLD,3],[LIVETOPIC,22],[LIVETOPICOLD,28],[LIVETOPICOLD,45],[LIVETOPIC,1],[__consumer_offsets,21],[__consumer_offsets,22],[LIVETOPIC,33],[LIVETOPIC,36],[LIVETOPIC,47],[LIVETOPICOLD,20],[LIVETOPICOLD,27],[__consumer_offsets,8],[LIVETOPICOLD,49],[LIVETOPICOLD,42],[LIVETOPICOLD,10],[LIVETOPICOLD,31],[LIVETOPIC,29],[LIVETOPICOLD,21],[__consumer_offsets,15],[__consumer_offsets,11],[LIVETOPIC,18],[LIVETOPIC,5],[LIVETOPIC,4],[__consumer_offsets,49],[LIVETOPICOLD,13],[__consumer_offsets,28],[__consumer_offsets,4],[LIVETOPIC,12],[LIVETOPICOLD,34],[__consumer_offsets,42],[LIVETOPIC,26],[LIVETOPIC,15],[__consumer_offsets,46],[__consumer_offsets,25],[LIVETOPICOLD,24],[LIVETOPICOLD,14],[__consumer_offsets,32],[__consumer_offsets,43],[LIVETOPIC,39],[LIVETOPIC,40],[LIVETOPIC,25],[__consumer_offsets,36],[LIVETOPIC,19],[__consumer_offsets,35],[__consumer_offsets,7],[LIVETOPIC,8],[LIVETOPICOLD,48],[__consumer_offsets,1],[LIVETOPICOLD,6],[LIVETOPICOLD,41],[LIVETOPICOLD,7],[LIVETOPICOLD,17]
(kafka.controller.PartitionStateMachine)
[2017-12-02 02:47:36,117] DEBUG [Channel manager on controller 1]:
Controller 1 trying to connect to broker 2
(kafka.controller.ControllerChannelManager)
[2017-12-02 02:47:36,117] INFO [Controller-1-to-broker-2-send-thread],
Starting  (kafka.controller.RequestSendThread)
[2017-12-02 02:47:36,117] INFO [Controller-1-to-broker-1-send-thread],
Starting  (kafka.controller.RequestSendThread)
[2017-12-02 02:47:36,242] INFO [Controller 1]: Partitions undergoing
preferred replica election:  (kafka.controller.KafkaController)
[2017-12-02 02:47:36,242] INFO [Controller 1]: Partitions that
completed preferred replica election:
(kafka.controller.KafkaController)
[2017-12-02 02:47:36,242] INFO [Controller 1]: Resuming preferred
replica election for partitions:  (kafka.controller.KafkaController)
[2017-12-02 02:47:36,242] DEBUG [OfflinePartitionLeaderSelector]: Some
broker in ISR is alive for [LIVETOPIC,11]. Select 2 from ISR 2 to be
the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,242] INFO [OfflinePartitionLeaderSelector]:
Selected new leader and ISR {"leader":2,"leader_epoch":1,"isr":[2]}
for offline partition [LIVETOPIC,11]
(kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,242] INFO [Controller 1]: Partitions being
reassigned: Map() (kafka.controller.KafkaController)
[2017-12-02 02:47:36,242] INFO [Controller 1]: Partitions already
reassigned: Set() (kafka.controller.KafkaController)
[2017-12-02 02:47:36,242] INFO [Controller 1]: Resuming reassignment
of partitions: Map() (kafka.controller.KafkaController)
[2017-12-02 02:47:36,273] INFO [Controller 1]: List of topics to be
deleted:  (kafka.controller.KafkaController)
[2017-12-02 02:47:36,273] INFO [Controller 1]: List of topics
ineligible for deletion: __consumer_offsets,LIVETOPIC,LIVETOPICOLD
(kafka.controller.KafkaController)
[2017-12-02 02:47:36,289] INFO [Controller 1]: Currently active
brokers in the cluster: Set(1, 2) (kafka.controller.KafkaController)
[2017-12-02 02:47:36,289] DEBUG [Partition state machine on Controller
0]: After leader election, leader cache is updated to
Map([__consumer_offsets,19] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,11]
-> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,30] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,18] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,46]
-> (Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,13] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,47] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,26] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,29] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,0]
-> (Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,41] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,44]
-> (Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,38] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,39] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,2]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,10] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,17] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,20]
-> (Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,4] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,23]
-> (Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,30] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,14] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,40] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,31]
-> (Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,43] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,19] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,35] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,18] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,43]
-> (Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,16] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,26] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,0] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,32]
-> (Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,24] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,3]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,22] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,2] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,33] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,3] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,22]
-> (Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,28] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,45] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,35]
-> (Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,20] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,1] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,33] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,21] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,3] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,5] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,22] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,47] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,33]
-> (Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,8] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,36]
-> (Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,47] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,11] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,20] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,48]
-> (Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,12] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,32] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,8] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,39] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,27] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,49] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,42] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,21]
-> (Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,10] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,31] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,29]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,23] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,21] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,15] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,48] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,11] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,18]
-> (Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,13] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,28]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,5]
-> (Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,45] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,25] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,6] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,4] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,23] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,37] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,6] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,49] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,13] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,28] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,4] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,37] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,12]
-> (Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,30] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,31] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,44] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,15] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,29] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,37]
-> (Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,34] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,38]
-> (Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,27] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,26]
-> (Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,42] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,15]
-> (Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,42] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,34] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,46] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,14]
-> (Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,1] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,12] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,7] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,25] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,34]
-> (Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,45] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,24] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,27] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,44] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,46] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,14] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,32] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,0] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,43] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,39]
-> (Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,5] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,10]
-> (Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,9]
-> (Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,24] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,36] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,40]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,25] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,36] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,19]
-> (Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,35] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,7] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,8] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,40] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,38] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,9] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,48] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,16]
-> (Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,9] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,1] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,41]
-> (Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,6] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,41] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,7]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,17] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,17] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,49]
-> (Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,16] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,2] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1))
(kafka.controller.PartitionStateMachine)
[2017-12-02 02:47:36,289] INFO [Controller 1]: Currently shutting
brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-12-02 02:47:36,289] INFO [Controller 1]: Current list of topics
in the cluster: Set(LIVETOPIC, LIVETOPICOLD, __consumer_offsets)
(kafka.controller.KafkaController)
[2017-12-02 02:47:36,289] DEBUG [OfflinePartitionLeaderSelector]: Some
broker in ISR is alive for [LIVETOPIC,46]. Select 1 from ISR 1,2 to be
the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,289] INFO [OfflinePartitionLeaderSelector]:
Selected new leader and ISR {"leader":1,"leader_epoch":1,"isr":[1,2]}
for offline partition [LIVETOPIC,46]
(kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,320] DEBUG [Partition state machine on Controller
0]: After leader election, leader cache is updated to
Map([__consumer_offsets,19] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,11]
-> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,30] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,18] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,46]
-> (Leader:1,ISR:1,2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPIC,13]
-> (Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,47] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,26] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,29] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,0]
-> (Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,41] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,44]
-> (Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,38] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,39] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,2]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,10] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,17] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,20]
-> (Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,4] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,23]
-> (Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,30] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,14] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,40] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,31]
-> (Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,43] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,19] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,35] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,18] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,43]
-> (Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,16] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,26] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,0] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,32]
-> (Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,24] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,3]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,22] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,2] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,33] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,3] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,22]
-> (Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,28] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,45] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,35]
-> (Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,20] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,1] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,33] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,21] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,3] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,5] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,22] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,47] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,33]
-> (Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,8] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,36]
-> (Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,47] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,11] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,20] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,48]
-> (Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,12] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,32] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,8] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,39] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,27] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,49] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,42] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,21]
-> (Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,10] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,31] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,29]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,23] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,21] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,15] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,48] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,11] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,18]
-> (Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,13] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,28]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,5]
-> (Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,45] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,25] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,6] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,4] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,23] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,37] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,6] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,49] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,13] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,28] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,4] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,37] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,12]
-> (Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,30] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,31] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,44] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,15] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,29] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,37]
-> (Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,34] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,38]
-> (Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,27] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,26]
-> (Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,42] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,15]
-> (Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,42] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,34] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,46] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,14]
-> (Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,1] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,12] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,7] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,25] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,34]
-> (Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,45] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,24] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,27] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,44] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,46] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,14] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,32] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,0] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,43] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,39]
-> (Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,5] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,10]
-> (Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,9]
-> (Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,24] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,36] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,40]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,25] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,36] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,19]
-> (Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,35] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,7] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,8] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,40] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,38] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,9] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,48] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,16]
-> (Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,9] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,1] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,41]
-> (Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,6] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,41] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,7]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,17] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,17] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,49]
-> (Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,16] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,2] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1))
(kafka.controller.PartitionStateMachine)
[2017-12-02 02:47:36,320] INFO [Replica state machine on controller
1]: Invoking state change to OnlineReplica for replicas
[Topic=__consumer_offsets,Partition=28,Replica=1],[Topic=__consumer_offsets,Partition=17,Replica=2],[Topic=LIVETOPICOLD,Partition=4,Replica=1],[Topic=LIVETOPICOLD,Partition=2,Replica=2],[Topic=__consumer_offsets,Partition=5,Replica=1],[Topic=__consumer_offsets,Partition=21,Replica=1],[Topic=LIVETOPICOLD,Partition=14,Replica=2],[Topic=LIVETOPIC,Partition=34,Replica=2],[Topic=__consumer_offsets,Partition=23,Replica=2],[Topic=__consumer_offsets,Partition=48,Replica=2],[Topic=LIVETOPICOLD,Partition=46,Replica=1],[Topic=LIVETOPICOLD,Partition=31,Replica=2],[Topic=__consumer_offsets,Partition=9,Replica=1],[Topic=LIVETOPICOLD,Partition=47,Replica=2],[Topic=__consumer_offsets,Partition=39,Replica=1],[Topic=LIVETOPIC,Partition=15,Replica=1],[Topic=LIVETOPIC,Partition=2,Replica=1],[Topic=LIVETOPIC,Partition=40,Replica=1],[Topic=LIVETOPICOLD,Partition=12,Replica=2],[Topic=LIVETOPIC,Partition=46,Replica=2],[Topic=__consumer_offsets,Partition=22,Replica=2],[Topic=LIVETOPICOLD,Partition=20,Replica=2],[Topic=LIVETOPICOLD,Partition=43,Replica=1],[Topic=__consumer_offsets,Partition=19,Replica=1],[Topic=LIVETOPIC,Partition=27,Replica=1],[Topic=LIVETOPICOLD,Partition=7,Replica=1],[Topic=__consumer_offsets,Partition=10,Replica=1],[Topic=LIVETOPIC,Partition=23,Replica=1],[Topic=LIVETOPICOLD,Partition=37,Replica=2],[Topic=__consumer_offsets,Partition=13,Replica=2],[Topic=__consumer_offsets,Partition=34,Replica=2],[Topic=LIVETOPICOLD,Partition=26,Replica=1],[Topic=__consumer_offsets,Partition=22,Replica=1],[Topic=__consumer_offsets,Partition=40,Replica=2],[Topic=LIVETOPICOLD,Partition=5,Replica=2],[Topic=LIVETOPICOLD,Partition=39,Replica=1],[Topic=LIVETOPIC,Partition=47,Replica=2],[Topic=LIVETOPIC,Partition=45,Replica=2],[Topic=LIVETOPIC,Partition=16,Replica=1],[Topic=LIVETOPIC,Partition=8,Replica=1],[Topic=LIVETOPIC,Partition=5,Replica=2],[Topic=LIVETOPICOLD,Partition=49,Replica=2],[Topic=LIVETOPICOLD,Partition=30,Replica=1],[Topic=LIVETOPIC,Partition=31,Replica=2],[Topic=__consumer_offsets,Partition=40,Replica=1],[Topic=LIVETOPICOLD,Partition=26,Replica=2],[Topic=__consumer_offsets,Partition=11,Replica=2],[Topic=LIVETOPICOLD,Partition=18,Replica=1],[Topic=__consumer_offsets,Partition=20,Replica=2],[Topic=__consumer_offsets,Partition=47,Replica=1],[Topic=__consumer_offsets,Partition=27,Replica=2],[Topic=__consumer_offsets,Partition=41,Replica=1],[Topic=LIVETOPICOLD,Partition=13,Replica=1],[Topic=LIVETOPICOLD,Partition=19,Replica=1],[Topic=LIVETOPICOLD,Partition=32,Replica=1],[Topic=LIVETOPICOLD,Partition=38,Replica=2],[Topic=LIVETOPIC,Partition=3,Replica=2],[Topic=LIVETOPICOLD,Partition=36,Replica=1],[Topic=__consumer_offsets,Partition=3,Replica=1],[Topic=__consumer_offsets,Partition=28,Replica=2],[Topic=LIVETOPIC,Partition=30,Replica=1],[Topic=__consumer_offsets,Partition=10,Replica=2],[Topic=__consumer_offsets,Partition=4,Replica=1],[Topic=__consumer_offsets,Partition=16,Replica=1],[Topic=__consumer_offsets,Partition=46,Replica=1],[Topic=LIVETOPICOLD,Partition=42,Replica=1],[Topic=LIVETOPICOLD,Partition=40,Replica=2],[Topic=LIVETOPIC,Partition=4,Replica=2],[Topic=LIVETOPIC,Partition=17,Replica=2],[Topic=LIVETOPIC,Partition=3,Replica=1],[Topic=__consumer_offsets,Partition=4,Replica=2],[Topic=__consumer_offsets,Partition=35,Replica=2],[Topic=LIVETOPIC,Partition=40,Replica=2],[Topic=LIVETOPIC,Partition=9,Replica=1],[Topic=LIVETOPIC,Partition=28,Replica=2],[Topic=__consumer_offsets,Partition=45,Replica=1],[Topic=__consumer_offsets,Partition=46,Replica=2],[Topic=LIVETOPICOLD,Partition=24,Replica=1],[Topic=LIVETOPIC,Partition=9,Replica=2],[Topic=LIVETOPICOLD,Partition=11,Replica=1],[Topic=LIVETOPICOLD,Partition=49,Replica=1],[Topic=LIVETOPICOLD,Partition=44,Replica=2],[Topic=LIVETOPICOLD,Partition=0,Replica=1],[Topic=__consumer_offsets,Partition=6,Replica=2],[Topic=LIVETOPIC,Partition=15,Replica=2],[Topic=LIVETOPICOLD,Partition=19,Replica=2],[Topic=LIVETOPIC,Partition=45,Replica=1],[Topic=LIVETOPIC,Partition=33,Replica=1],[Topic=LIVETOPICOLD,Partition=31,Replica=1],[Topic=LIVETOPICOLD,Partition=33,Replica=2],[Topic=LIVETOPIC,Partition=21,Replica=1],[Topic=LIVETOPIC,Partition=46,Replica=1],[Topic=LIVETOPICOLD,Partition=7,Replica=2],[Topic=LIVETOPIC,Partition=34,Replica=1],[Topic=LIVETOPIC,Partition=22,Replica=2],[Topic=LIVETOPIC,Partition=21,Replica=2],[Topic=LIVETOPIC,Partition=10,Replica=1],[Topic=LIVETOPIC,Partition=11,Replica=2],[Topic=LIVETOPICOLD,Partition=25,Replica=1],[Topic=LIVETOPIC,Partition=10,Replica=2],[Topic=LIVETOPIC,Partition=39,Replica=1],[Topic=LIVETOPIC,Partition=44,Replica=1],[Topic=__consumer_offsets,Partition=34,Replica=1],[Topic=__consumer_offsets,Partition=33,Replica=1],[Topic=LIVETOPICOLD,Partition=1,Replica=1],[Topic=LIVETOPIC,Partition=4,Replica=1],[Topic=__consumer_offsets,Partition=26,Replica=1],[Topic=LIVETOPIC,Partition=38,Replica=2],[Topic=LIVETOPICOLD,Partition=20,Replica=1],[Topic=LIVETOPICOLD,Partition=1,Replica=2],[Topic=LIVETOPIC,Partition=37,Replica=1],[Topic=LIVETOPIC,Partition=14,Replica=1],[Topic=LIVETOPIC,Partition=16,Replica=2],[Topic=__consumer_offsets,Partition=5,Replica=2],[Topic=__consumer_offsets,Partition=41,Replica=2],[Topic=LIVETOPICOLD,Partition=25,Replica=2],[Topic=__consumer_offsets,Partition=47,Replica=2],[Topic=LIVETOPIC,Partition=41,Replica=2],[Topic=LIVETOPICOLD,Partition=27,Replica=2],[Topic=__consumer_offsets,Partition=12,Replica=1],[Topic=__consumer_offsets,Partition=16,Replica=2],[Topic=__consumer_offsets,Partition=29,Replica=2],[Topic=LIVETOPICOLD,Partition=8,Replica=2],[Topic=__consumer_offsets,Partition=15,Replica=1],[Topic=LIVETOPICOLD,Partition=37,Replica=1],[Topic=LIVETOPIC,Partition=24,Replica=2],[Topic=LIVETOPICOLD,Partition=32,Replica=2],[Topic=LIVETOPICOLD,Partition=43,Replica=2]
(kafka.controller.ReplicaStateMachine)
[2017-12-02 02:47:36,320] DEBUG [OfflinePartitionLeaderSelector]: Some
broker in ISR is alive for [__consumer_offsets,29]. Select 2 from ISR
2 to be the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,320] INFO [OfflinePartitionLeaderSelector]:
Selected new leader and ISR {"leader":2,"leader_epoch":1,"isr":[2]}
for offline partition [__consumer_offsets,29]
(kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,352] DEBUG [Partition state machine on Controller
0]: After leader election, leader cache is updated to
Map([__consumer_offsets,19] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,11]
-> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,30] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,18] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,46]
-> (Leader:1,ISR:1,2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPIC,13]
-> (Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,47] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,26] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,29] ->
(Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPICOLD,0] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,41] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,44]
-> (Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,38] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,39] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,2]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,10] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,17] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,20]
-> (Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,4] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,23]
-> (Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,30] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,14] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,40] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,31]
-> (Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,43] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,19] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,35] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,18] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,43]
-> (Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,16] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,26] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,0] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,32]
-> (Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,24] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,3]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,22] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,2] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,33] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,3] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,22]
-> (Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,28] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,45] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,35]
-> (Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,20] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,1] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,33] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,21] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,3] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,5] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,22] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,47] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,33]
-> (Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,8] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,36]
-> (Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,47] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,11] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,20] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,48]
-> (Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,12] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,32] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,8] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,39] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,27] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,49] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,42] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,21]
-> (Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,10] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,31] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,29]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,23] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,21] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,15] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,48] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,11] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,18]
-> (Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,13] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,28]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,5]
-> (Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,45] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,25] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,6] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,4] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,23] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,37] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,6] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,49] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,13] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,28] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,4] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,37] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,12]
-> (Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,30] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,31] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,44] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,15] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,29] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,37]
-> (Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,34] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,38]
-> (Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,27] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,26]
-> (Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,42] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,15]
-> (Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,42] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,34] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,46] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,14]
-> (Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,1] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,12] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,7] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,25] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,34]
-> (Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,45] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,24] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,27] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,44] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,46] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,14] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,32] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,0] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,43] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,39]
-> (Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,5] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,10]
-> (Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,9]
-> (Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,24] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,36] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,40]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,25] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,36] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,19]
-> (Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,35] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,7] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,8] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,40] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,38] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,9] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,48] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,16]
-> (Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,9] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,1] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,41]
-> (Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,6] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,41] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,7]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,17] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,17] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,49]
-> (Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,16] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,2] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1))
(kafka.controller.PartitionStateMachine)
[2017-12-02 02:47:36,352] DEBUG [OfflinePartitionLeaderSelector]: Some
broker in ISR is alive for [LIVETOPICOLD,0]. Select 1 from ISR 1 to be
the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,352] INFO [OfflinePartitionLeaderSelector]:
Selected new leader and ISR {"leader":1,"leader_epoch":1,"isr":[1]}
for offline partition [LIVETOPICOLD,0]
(kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,383] DEBUG [Partition state machine on Controller
0]: After leader election, leader cache is updated to
Map([__consumer_offsets,19] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,11]
-> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,30] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,18] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,46]
-> (Leader:1,ISR:1,2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPIC,13]
-> (Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,47] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,26] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,29] ->
(Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPICOLD,0] ->
(Leader:1,ISR:1,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,41] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,44]
-> (Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,38] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,39] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,2]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,10] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,17] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,20]
-> (Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,4] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,23]
-> (Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,30] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,14] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,40] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,31]
-> (Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,43] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,19] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,35] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,18] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,43]
-> (Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,16] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,26] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,0] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,32]
-> (Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,24] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,3]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,22] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,2] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,33] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,3] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,22]
-> (Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,28] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,45] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,35]
-> (Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,20] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,1] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,33] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,21] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,3] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,5] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,22] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,47] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,33]
-> (Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,8] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,36]
-> (Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,47] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,11] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,20] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,48]
-> (Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,12] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,32] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,8] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,39] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,27] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,49] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,42] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,21]
-> (Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,10] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,31] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,29]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,23] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,21] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,15] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,48] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,11] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,18]
-> (Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,13] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,28]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,5]
-> (Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,45] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,25] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,6] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,4] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,23] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,37] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,6] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,49] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,13] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,28] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,4] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,37] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,12]
-> (Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,30] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,31] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,44] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,15] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,29] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,37]
-> (Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,34] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,38]
-> (Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,27] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,26]
-> (Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,42] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,15]
-> (Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,42] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,34] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,46] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,14]
-> (Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,1] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,12] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,7] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,25] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,34]
-> (Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,45] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,24] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,27] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,44] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,46] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,14] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,32] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,0] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,43] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,39]
-> (Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,5] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,10]
-> (Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,9]
-> (Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,24] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,36] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,40]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,25] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,36] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,19]
-> (Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,35] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,7] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,8] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,40] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,38] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,9] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,48] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,16]
-> (Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,9] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,1] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,41]
-> (Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,6] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,41] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,7]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,17] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,17] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,49]
-> (Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,16] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,2] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1))
(kafka.controller.PartitionStateMachine)
[2017-12-02 02:47:36,398] DEBUG [OfflinePartitionLeaderSelector]: Some
broker in ISR is alive for [LIVETOPICOLD,38]. Select 2 from ISR 2 to
be the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,398] INFO [OfflinePartitionLeaderSelector]:
Selected new leader and ISR {"leader":2,"leader_epoch":1,"isr":[2]}
for offline partition [LIVETOPICOLD,38]
(kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,414] DEBUG [Partition state machine on Controller
0]: After leader election, leader cache is updated to
Map([__consumer_offsets,19] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,11]
-> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,30] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,18] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,46]
-> (Leader:1,ISR:1,2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPIC,13]
-> (Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,47] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,26] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,29] ->
(Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPICOLD,0] ->
(Leader:1,ISR:1,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,41] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,44]
-> (Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,38] -> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,39] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,2]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,10] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,17] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,20]
-> (Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,4] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,23]
-> (Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,30] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,14] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,40] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,31]
-> (Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,43] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,19] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,35] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,18] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,43]
-> (Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,16] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,26] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,0] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,32]
-> (Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,24] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,3]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,22] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,2] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,33] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,3] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,22]
-> (Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,28] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,45] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,35]
-> (Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,20] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,1] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,33] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,21] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,3] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,5] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,22] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,47] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,33]
-> (Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,8] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,36]
-> (Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,47] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,11] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,20] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,48]
-> (Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,12] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,32] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,8] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,39] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,27] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,49] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,42] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,21]
-> (Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,10] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,31] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,29]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,23] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,21] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,15] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,48] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,11] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,18]
-> (Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,13] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,28]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,5]
-> (Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,45] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,25] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,6] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,4] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,23] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,37] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,6] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,49] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,13] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,28] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,4] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,37] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,12]
-> (Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,30] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,31] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,44] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,15] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,29] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,37]
-> (Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,34] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,38]
-> (Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,27] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,26]
-> (Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,42] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,15]
-> (Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,42] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,34] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,46] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,14]
-> (Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,1] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,12] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,7] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,25] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,34]
-> (Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,45] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,24] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,27] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,44] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,46] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,14] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,32] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,0] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,43] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,39]
-> (Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,5] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,10]
-> (Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,9]
-> (Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,24] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,36] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,40]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,25] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,36] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,19]
-> (Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,35] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,7] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,8] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,40] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,38] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,9] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,48] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,16]
-> (Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,9] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,1] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,41]
-> (Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,6] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,41] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,7]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,17] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,17] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,49]
-> (Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,16] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,2] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1))
(kafka.controller.PartitionStateMachine)
[2017-12-02 02:47:36,430] DEBUG [OfflinePartitionLeaderSelector]: Some
broker in ISR is alive for [__consumer_offsets,39]. Select 6 from ISR
6,1 to be the leader.
(kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,430] INFO [OfflinePartitionLeaderSelector]:
Selected new leader and ISR {"leader":6,"leader_epoch":1,"isr":[6,1]}
for offline partition [__consumer_offsets,39]
(kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,445] INFO [Controller-1-to-broker-2-send-thread],
Controller 1 connected to 10.83.24.37:9095 (id: 2 rack: null) for
sending state change requests (kafka.controller.RequestSendThread)
[2017-12-02 02:47:36,445] INFO [Controller-1-to-broker-1-send-thread],
Controller 1 connected to 10.83.24.37:9094 (id: 1 rack: null) for
sending state change requests (kafka.controller.RequestSendThread)
[2017-12-02 02:47:36,461] DEBUG [Partition state machine on Controller
0]: After leader election, leader cache is updated to
Map([__consumer_offsets,19] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,11]
-> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,30] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,18] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,46]
-> (Leader:1,ISR:1,2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPIC,13]
-> (Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,47] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,26] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,29] ->
(Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPICOLD,0] ->
(Leader:1,ISR:1,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,41] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,44]
-> (Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,38] -> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,39] ->
(Leader:6,ISR:6,1,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPICOLD,2]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,10] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,17] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,20]
-> (Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,4] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,23]
-> (Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,30] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,14] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,40] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,31]
-> (Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,43] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,19] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,35] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,18] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,43]
-> (Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,16] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,26] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,0] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,32]
-> (Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,24] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,3]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,22] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,2] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,33] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,3] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,22]
-> (Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,28] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,45] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,35]
-> (Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,20] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,1] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,33] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,21] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,3] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,5] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,22] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,47] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,33]
-> (Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,8] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,36]
-> (Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,47] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,11] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,20] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,48]
-> (Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,12] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,32] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,8] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,39] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,27] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,49] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,42] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,21]
-> (Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,10] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,31] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,29]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,23] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,21] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,15] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,48] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,11] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,18]
-> (Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,13] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,28]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,5]
-> (Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,45] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,25] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,6] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,4] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,23] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,37] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,6] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,49] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,13] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,28] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,4] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,37] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,12]
-> (Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,30] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,31] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,44] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,15] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,29] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,37]
-> (Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,34] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,38]
-> (Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,27] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,26]
-> (Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,42] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,15]
-> (Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,42] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,34] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,46] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,14]
-> (Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,1] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,12] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,7] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,25] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,34]
-> (Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,45] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,24] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,27] ->
(Leader:2,ISR:2,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,44] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,46] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,14] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,32] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,0] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,43] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,39]
-> (Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,5] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,10]
-> (Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,9]
-> (Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,24] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,36] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,40]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,25] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,36] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,19]
-> (Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,35] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,7] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,8] ->
(Leader:0,ISR:0,6,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,40] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,38] ->
(Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,9] ->
(Leader:5,ISR:5,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,48] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,16]
-> (Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,9] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,1] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,41]
-> (Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,6] ->
(Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,41] ->
(Leader:3,ISR:3,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,7]
-> (Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,17] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,17] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,49]
-> (Leader:6,ISR:6,5,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,16] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,2] ->
(Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1))
(kafka.controller.PartitionStateMachine)
[2017-12-02 02:47:36,461] DEBUG [OfflinePartitionLeaderSelector]: Some
broker in ISR is alive for [__consumer_offsets,14]. Select 6 from ISR
6 to be the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,461] INFO [OfflinePartitionLeaderSelector]:
Selected new leader and ISR {"leader":6,"leader_epoch":1,"isr":[6]}
for offline partition [__consumer_offsets,14]
(kafka.controller.OfflinePartitionLeaderSelector)
[2017-12-02 02:47:36,492] DEBUG [Partition state machine on Controller
0]: After leader election, leader cache is updated to
Map([__consumer_offsets,19] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,11]
-> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,30] ->
(Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,18] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,46]
-> (Leader:1,ISR:1,2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPIC,13]
-> (Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,47] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,26] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,29] ->
(Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPICOLD,0] ->
(Leader:1,ISR:1,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,41] ->
(Leader:2,ISR:2,1,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,44]
-> (Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,38] -> (Leader:2,ISR:2,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,39] ->
(Leader:6,ISR:6,1,LeaderEpoch:1,ControllerEpoch:1), [LIVETOPICOLD,2]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,10] ->
(Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,17] ->
(Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,20]
-> (Leader:5,ISR:5,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,4] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,23]
-> (Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,30] ->
(Leader:1,ISR:1,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,14] ->
(Leader:6,ISR:6,LeaderEpoch:1,ControllerEpoch:1),
[__consumer_offsets,40] ->
(Leader:1,ISR:1,0,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,31]
-> (Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,43] ->
(Leader:5,ISR:5,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,19] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,35] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,18] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,43]
-> (Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,16] ->
(Leader:6,ISR:6,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,26] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,0] ->
(Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,32]
-> (Leader:3,ISR:3,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,24] ->
(Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPICOLD,3]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,22] ->
(Leader:5,ISR:5,4,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,2] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,33] ->
(Leader:1,ISR:1,6,0,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,3] ->
(Leader:2,ISR:2,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,22]
-> (Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,28] ->
(Leader:4,ISR:4,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,45] ->
(Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,35]
-> (Leader:6,ISR:6,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,20] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,1] ->
(Leader:0,ISR:0,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,33] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,21] ->
(Leader:3,ISR:3,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,3] ->
(Leader:6,ISR:6,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,5] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,22] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,47] ->
(Leader:2,ISR:2,5,6,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,33]
-> (Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,8] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,36]
-> (Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPIC,47] ->
(Leader:4,ISR:4,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,11] ->
(Leader:1,ISR:1,5,6,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,20] ->
(Leader:3,ISR:3,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,48]
-> (Leader:5,ISR:5,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,12] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,32] ->
(Leader:1,ISR:1,2,3,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,8] ->
(Leader:4,ISR:4,6,0,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,39] ->
(Leader:1,ISR:1,3,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,27] ->
(Leader:3,ISR:3,2,4,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,49] ->
(Leader:4,ISR:4,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,42] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,21]
-> (Leader:6,ISR:6,1,2,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,10] ->
(Leader:0,ISR:0,4,5,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,31] ->
(Leader:0,ISR:0,1,2,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,29]
-> (Leader:0,ISR:0,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,23] ->
(Leader:5,ISR:5,2,3,LeaderEpoch:0,ControllerEpoch:1),
[LIVETOPICOLD,21] ->
(Leader:4,ISR:4,3,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,15] ->
(Leader:4,ISR:4,0,1,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,48] ->
(Leader:2,ISR:2,3,4,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,11] ->
(Leader:0,ISR:0,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,18]
-> (Leader:3,ISR:3,4,5,LeaderEpoch:0,ControllerEpoch:1),
[__consumer_offsets,13] ->
(Leader:2,ISR:2,4,5,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,28]
-> (Leader:6,ISR:6,2,3,LeaderEpoch:0,ControllerEpoch:1), [LIVETOPIC,5]
-> (Leader:4,ISR:4,2,3,LeaderEpoch:0

...