[2017-11-23 17:06:15,110] INFO [SessionExpirationListener on 0], ZK expired; shut down all controller components and try to re-elect (kafka.controller.KafkaController$SessionExpirationListener)
[2017-11-23 17:06:15,115] INFO [delete-topics-thread-0], Shutting down (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:06:15,116] INFO [delete-topics-thread-0], Stopped  (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:06:15,116] INFO [delete-topics-thread-0], Shutdown completed (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:06:15,126] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
[2017-11-23 17:06:15,127] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:06:15,127] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread)
[2017-11-23 17:06:15,128] INFO [Controller-0-to-broker-0-send-thread], Stopped  (kafka.controller.RequestSendThread)
[2017-11-23 17:06:15,128] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread)
[2017-11-23 17:06:15,133] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController)
[2017-11-23 17:06:15,135] INFO [Controller 0]: Initialized controller epoch to 2 and zk version 1 (kafka.controller.KafkaController)
[2017-11-23 17:06:15,137] INFO [Controller 0]: Controller 0 incremented epoch to 3 (kafka.controller.KafkaController)
[2017-11-23 17:06:15,156] INFO [Controller 0]: Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
[2017-11-23 17:06:15,156] INFO [Controller 0]: Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
[2017-11-23 17:06:15,156] INFO [Controller 0]: Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
[2017-11-23 17:06:15,157] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController)
[2017-11-23 17:06:15,157] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController)
[2017-11-23 17:06:15,157] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController)
[2017-11-23 17:06:15,160] INFO [Controller 0]: List of topics to be deleted:  (kafka.controller.KafkaController)
[2017-11-23 17:06:15,160] INFO [Controller 0]: List of topics ineligible for deletion: topic (kafka.controller.KafkaController)
[2017-11-23 17:06:15,160] INFO [Controller 0]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-11-23 17:06:15,160] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-11-23 17:06:15,160] INFO [Controller 0]: Current list of topics in the cluster: Set(topic) (kafka.controller.KafkaController)
[2017-11-23 17:06:15,161] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map([Topic=topic,Partition=0,Replica=0] -> ReplicaDeletionIneligible) (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:06:15,183] DEBUG [OfflinePartitionLeaderSelector]: No broker in ISR is alive for [topic,0]. Pick the leader from the alive assigned replicas:  (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:06:15,186] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map([topic,0] -> OfflinePartition) (kafka.controller.PartitionStateMachine)
[2017-11-23 17:06:15,187] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 3 (kafka.controller.KafkaController)
[2017-11-23 17:06:15,187] INFO [Controller 0]: Starting preferred replica leader election for partitions  (kafka.controller.KafkaController)
[2017-11-23 17:06:15,187] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions  (kafka.controller.PartitionStateMachine)
[2017-11-23 17:06:15,191] INFO [Controller 0]: starting the partition rebalance scheduler (kafka.controller.KafkaController)
[2017-11-23 17:06:15,201] INFO [delete-topics-thread-0], Starting  (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:06:15,201] DEBUG [Topic Deletion Manager 0], Waiting for signal to start or continue topic deletion (kafka.controller.TopicDeletionManager)
[2017-11-23 17:06:15,218] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:06:15,236] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:06:15,236] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager)
[2017-11-23 17:06:15,241] INFO [Controller-0-to-broker-0-send-thread], Controller 0 connected to id:0,host:silvio-VirtualBox,port:9092 for sending state change requests (kafka.controller.RequestSendThread)
[2017-11-23 17:06:15,242] INFO [Controller 0]: New broker startup callback for 0 (kafka.controller.KafkaController)
[2017-11-23 17:06:15,242] INFO [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=topic,Partition=0,Replica=0] (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:06:15,248] INFO [Controller-0-to-broker-0-send-thread], Starting  (kafka.controller.RequestSendThread)
[2017-11-23 17:06:15,266] DEBUG [OfflinePartitionLeaderSelector]: Some broker in ISR is alive for [topic,0]. Select 0 from ISR 0 to be the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:06:15,267] INFO [OfflinePartitionLeaderSelector]: Selected new leader and ISR {"leader":0,"leader_epoch":1,"isr":[0]} for offline partition [topic,0] (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:06:15,285] DEBUG [Partition state machine on Controller 0]: After leader election, leader cache is updated to Map([topic,0] -> (Leader:0,ISR:0,LeaderEpoch:1,ControllerEpoch:3)) (kafka.controller.PartitionStateMachine)
[2017-11-23 17:06:15,296] DEBUG [DeleteTopicsListener on 0]: Delete topics listener fired for topics  to be deleted (kafka.controller.PartitionStateMachine$DeleteTopicsListener)
[2017-11-23 17:06:15,303] DEBUG [TopicChangeListener on Controller 0]: Topic change listener fired for path /brokers/topics with children topic (kafka.controller.PartitionStateMachine$TopicChangeListener)
[2017-11-23 17:06:15,303] INFO [TopicChangeListener on Controller 0]: New topics: [Set()], deleted topics: [Set()], new partition replica assignment [Map()] (kafka.controller.PartitionStateMachine$TopicChangeListener)
[2017-11-23 17:06:15,325] INFO [AddPartitionsListener on 0]: Add Partition triggered {"version":1,"partitions":{"0":[0]}} for path /brokers/topics/topic (kafka.controller.PartitionStateMachine$AddPartitionsListener)
[2017-11-23 17:06:15,339] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:06:15,359] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: , deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:06:20,192] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
[2017-11-23 17:06:20,192] DEBUG [Controller 0]: preferred replicas by broker Map(0 -> Map([topic,0] -> List(0))) (kafka.controller.KafkaController)
[2017-11-23 17:06:20,192] DEBUG [Controller 0]: topics not in preferred replica Map() (kafka.controller.KafkaController)
[2017-11-23 17:06:20,192] TRACE [Controller 0]: leader imbalance ratio for broker 0 is 0,000000 (kafka.controller.KafkaController)
[2017-11-23 17:06:28,664] INFO [Controller 0]: Shutting down broker 0 (kafka.controller.KafkaController)
[2017-11-23 17:06:28,664] DEBUG [Controller 0]: All shutting down brokers: 0 (kafka.controller.KafkaController)
[2017-11-23 17:06:28,664] DEBUG [Controller 0]: Live brokers:  (kafka.controller.KafkaController)
[2017-11-23 17:06:28,668] TRACE [Controller 0]: All leaders = [topic,0] -> (Leader:0,ISR:0,LeaderEpoch:1,ControllerEpoch:3) (kafka.controller.KafkaController)
[2017-11-23 17:06:28,819] INFO [delete-topics-thread-0], Shutting down (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:06:28,819] INFO [delete-topics-thread-0], Stopped  (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:06:28,819] INFO [delete-topics-thread-0], Shutdown completed (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:06:28,820] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
[2017-11-23 17:06:28,820] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:06:28,820] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread)
[2017-11-23 17:06:28,826] INFO [Controller-0-to-broker-0-send-thread], Stopped  (kafka.controller.RequestSendThread)
[2017-11-23 17:06:28,826] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread)
[2017-11-23 17:06:31,348] INFO [Controller 0]: Controller starting up (kafka.controller.KafkaController)
[2017-11-23 17:06:31,368] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController)
[2017-11-23 17:06:31,377] INFO [Controller 0]: Initialized controller epoch to 3 and zk version 2 (kafka.controller.KafkaController)
[2017-11-23 17:06:31,387] INFO [Controller 0]: Controller 0 incremented epoch to 4 (kafka.controller.KafkaController)
[2017-11-23 17:06:31,444] INFO [Controller 0]: Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
[2017-11-23 17:06:31,445] INFO [Controller 0]: Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
[2017-11-23 17:06:31,445] INFO [Controller 0]: Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
[2017-11-23 17:06:31,448] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController)
[2017-11-23 17:06:31,449] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController)
[2017-11-23 17:06:31,450] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController)
[2017-11-23 17:06:31,454] INFO [Controller 0]: List of topics to be deleted:  (kafka.controller.KafkaController)
[2017-11-23 17:06:31,455] INFO [Controller 0]: List of topics ineligible for deletion: topic (kafka.controller.KafkaController)
[2017-11-23 17:06:31,459] INFO [Controller 0]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-11-23 17:06:31,459] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-11-23 17:06:31,460] INFO [Controller 0]: Current list of topics in the cluster: Set(topic) (kafka.controller.KafkaController)
[2017-11-23 17:06:31,463] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map([Topic=topic,Partition=0,Replica=0] -> ReplicaDeletionIneligible) (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:06:31,484] DEBUG [OfflinePartitionLeaderSelector]: No broker in ISR is alive for [topic,0]. Pick the leader from the alive assigned replicas:  (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:06:31,493] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map([topic,0] -> OfflinePartition) (kafka.controller.PartitionStateMachine)
[2017-11-23 17:06:31,496] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 4 (kafka.controller.KafkaController)
[2017-11-23 17:06:31,497] INFO [Controller 0]: Starting preferred replica leader election for partitions  (kafka.controller.KafkaController)
[2017-11-23 17:06:31,497] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions  (kafka.controller.PartitionStateMachine)
[2017-11-23 17:06:31,504] INFO [Controller 0]: starting the partition rebalance scheduler (kafka.controller.KafkaController)
[2017-11-23 17:06:31,506] INFO [Controller 0]: Controller startup complete (kafka.controller.KafkaController)
[2017-11-23 17:06:31,511] INFO [delete-topics-thread-0], Starting  (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:06:31,512] DEBUG [Topic Deletion Manager 0], Waiting for signal to start or continue topic deletion (kafka.controller.TopicDeletionManager)
[2017-11-23 17:06:31,523] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:06:31,581] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:06:31,582] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager)
[2017-11-23 17:06:31,591] INFO [Controller-0-to-broker-0-send-thread], Controller 0 connected to id:0,host:silvio-VirtualBox,port:9092 for sending state change requests (kafka.controller.RequestSendThread)
[2017-11-23 17:06:31,596] INFO [Controller 0]: New broker startup callback for 0 (kafka.controller.KafkaController)
[2017-11-23 17:06:31,602] INFO [Controller-0-to-broker-0-send-thread], Starting  (kafka.controller.RequestSendThread)
[2017-11-23 17:06:31,622] INFO [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=topic,Partition=0,Replica=0] (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:06:31,652] DEBUG [OfflinePartitionLeaderSelector]: Some broker in ISR is alive for [topic,0]. Select 0 from ISR 0 to be the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:06:31,654] INFO [OfflinePartitionLeaderSelector]: Selected new leader and ISR {"leader":0,"leader_epoch":2,"isr":[0]} for offline partition [topic,0] (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:06:31,663] DEBUG [Partition state machine on Controller 0]: After leader election, leader cache is updated to Map([topic,0] -> (Leader:0,ISR:0,LeaderEpoch:2,ControllerEpoch:4)) (kafka.controller.PartitionStateMachine)
[2017-11-23 17:06:36,508] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
[2017-11-23 17:06:36,511] DEBUG [Controller 0]: preferred replicas by broker Map(0 -> Map([topic,0] -> List(0))) (kafka.controller.KafkaController)
[2017-11-23 17:06:36,513] DEBUG [Controller 0]: topics not in preferred replica Map() (kafka.controller.KafkaController)
[2017-11-23 17:06:36,514] TRACE [Controller 0]: leader imbalance ratio for broker 0 is 0,000000 (kafka.controller.KafkaController)
[2017-11-23 17:11:36,508] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
[2017-11-23 17:11:36,508] DEBUG [Controller 0]: preferred replicas by broker Map(0 -> Map([topic,0] -> List(0))) (kafka.controller.KafkaController)
[2017-11-23 17:11:36,508] DEBUG [Controller 0]: topics not in preferred replica Map() (kafka.controller.KafkaController)
[2017-11-23 17:11:36,508] TRACE [Controller 0]: leader imbalance ratio for broker 0 is 0,000000 (kafka.controller.KafkaController)
[2017-11-23 17:12:58,087] INFO [Controller 0]: Shutting down broker 0 (kafka.controller.KafkaController)
[2017-11-23 17:12:58,088] DEBUG [Controller 0]: All shutting down brokers: 0 (kafka.controller.KafkaController)
[2017-11-23 17:12:58,089] DEBUG [Controller 0]: Live brokers:  (kafka.controller.KafkaController)
[2017-11-23 17:12:58,093] TRACE [Controller 0]: All leaders = [topic,0] -> (Leader:0,ISR:0,LeaderEpoch:2,ControllerEpoch:4) (kafka.controller.KafkaController)
[2017-11-23 17:12:58,371] INFO [delete-topics-thread-0], Shutting down (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:12:58,371] INFO [delete-topics-thread-0], Stopped  (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:12:58,372] INFO [delete-topics-thread-0], Shutdown completed (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:12:58,374] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
[2017-11-23 17:12:58,374] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:12:58,375] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread)
[2017-11-23 17:12:58,375] INFO [Controller-0-to-broker-0-send-thread], Stopped  (kafka.controller.RequestSendThread)
[2017-11-23 17:12:58,375] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread)
[2017-11-23 17:13:35,510] DEBUG preRegister called. Server=com.sun.jmx.mbeanserver.JmxMBeanServer@66d3c617, name=log4j:logger=kafka.controller (kafka.controller)
[2017-11-23 17:14:27,087] INFO [Controller 0]: Controller starting up (kafka.controller.KafkaController)
[2017-11-23 17:14:27,150] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController)
[2017-11-23 17:14:27,159] INFO [Controller 0]: Initialized controller epoch to 4 and zk version 3 (kafka.controller.KafkaController)
[2017-11-23 17:14:27,167] INFO [Controller 0]: Controller 0 incremented epoch to 5 (kafka.controller.KafkaController)
[2017-11-23 17:14:27,274] INFO [Controller 0]: Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
[2017-11-23 17:14:27,278] INFO [Controller 0]: Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
[2017-11-23 17:14:27,279] INFO [Controller 0]: Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
[2017-11-23 17:14:27,282] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController)
[2017-11-23 17:14:27,283] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController)
[2017-11-23 17:14:27,284] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController)
[2017-11-23 17:14:27,288] INFO [Controller 0]: List of topics to be deleted:  (kafka.controller.KafkaController)
[2017-11-23 17:14:27,289] INFO [Controller 0]: List of topics ineligible for deletion: topic (kafka.controller.KafkaController)
[2017-11-23 17:14:27,294] INFO [Controller 0]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-11-23 17:14:27,297] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-11-23 17:14:27,298] INFO [Controller 0]: Current list of topics in the cluster: Set(topic) (kafka.controller.KafkaController)
[2017-11-23 17:14:27,301] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map([Topic=topic,Partition=0,Replica=0] -> ReplicaDeletionIneligible) (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:14:27,327] DEBUG [OfflinePartitionLeaderSelector]: No broker in ISR is alive for [topic,0]. Pick the leader from the alive assigned replicas:  (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:14:27,339] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map([topic,0] -> OfflinePartition) (kafka.controller.PartitionStateMachine)
[2017-11-23 17:14:27,350] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 5 (kafka.controller.KafkaController)
[2017-11-23 17:14:27,352] INFO [Controller 0]: Starting preferred replica leader election for partitions  (kafka.controller.KafkaController)
[2017-11-23 17:14:27,353] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions  (kafka.controller.PartitionStateMachine)
[2017-11-23 17:14:27,370] INFO [Controller 0]: starting the partition rebalance scheduler (kafka.controller.KafkaController)
[2017-11-23 17:14:27,373] INFO [Controller 0]: Controller startup complete (kafka.controller.KafkaController)
[2017-11-23 17:14:27,373] INFO [delete-topics-thread-0], Starting  (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:14:27,384] DEBUG [Topic Deletion Manager 0], Waiting for signal to start or continue topic deletion (kafka.controller.TopicDeletionManager)
[2017-11-23 17:14:27,401] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:14:27,454] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:14:27,454] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager)
[2017-11-23 17:14:27,469] INFO [Controller-0-to-broker-0-send-thread], Controller 0 connected to id:0,host:silvio-VirtualBox,port:9092 for sending state change requests (kafka.controller.RequestSendThread)
[2017-11-23 17:14:27,471] INFO [Controller 0]: New broker startup callback for 0 (kafka.controller.KafkaController)
[2017-11-23 17:14:27,481] INFO [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=topic,Partition=0,Replica=0] (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:14:27,482] INFO [Controller-0-to-broker-0-send-thread], Starting  (kafka.controller.RequestSendThread)
[2017-11-23 17:14:27,521] DEBUG [OfflinePartitionLeaderSelector]: Some broker in ISR is alive for [topic,0]. Select 0 from ISR 0 to be the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:14:27,526] INFO [OfflinePartitionLeaderSelector]: Selected new leader and ISR {"leader":0,"leader_epoch":3,"isr":[0]} for offline partition [topic,0] (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:14:27,535] DEBUG [Partition state machine on Controller 0]: After leader election, leader cache is updated to Map([topic,0] -> (Leader:0,ISR:0,LeaderEpoch:3,ControllerEpoch:5)) (kafka.controller.PartitionStateMachine)
[2017-11-23 17:14:32,377] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
[2017-11-23 17:14:32,379] DEBUG [Controller 0]: preferred replicas by broker Map(0 -> Map([topic,0] -> List(0))) (kafka.controller.KafkaController)
[2017-11-23 17:14:32,380] DEBUG [Controller 0]: topics not in preferred replica Map() (kafka.controller.KafkaController)
[2017-11-23 17:14:32,381] TRACE [Controller 0]: leader imbalance ratio for broker 0 is 0,000000 (kafka.controller.KafkaController)
[2017-11-23 17:15:23,548] INFO [Controller 0]: Shutting down broker 0 (kafka.controller.KafkaController)
[2017-11-23 17:15:23,549] DEBUG [Controller 0]: All shutting down brokers: 0 (kafka.controller.KafkaController)
[2017-11-23 17:15:23,549] DEBUG [Controller 0]: Live brokers:  (kafka.controller.KafkaController)
[2017-11-23 17:15:23,552] TRACE [Controller 0]: All leaders = [topic,0] -> (Leader:0,ISR:0,LeaderEpoch:3,ControllerEpoch:5) (kafka.controller.KafkaController)
[2017-11-23 17:15:23,882] INFO [delete-topics-thread-0], Shutting down (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:15:23,883] INFO [delete-topics-thread-0], Stopped  (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:15:23,883] INFO [delete-topics-thread-0], Shutdown completed (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:15:23,884] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
[2017-11-23 17:15:23,884] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:15:23,885] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread)
[2017-11-23 17:15:23,885] INFO [Controller-0-to-broker-0-send-thread], Stopped  (kafka.controller.RequestSendThread)
[2017-11-23 17:15:23,885] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread)
[2017-11-23 17:15:30,093] INFO [Controller 0]: Controller starting up (kafka.controller.KafkaController)
[2017-11-23 17:15:30,118] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController)
[2017-11-23 17:15:30,132] INFO [Controller 0]: Initialized controller epoch to 5 and zk version 4 (kafka.controller.KafkaController)
[2017-11-23 17:15:30,138] INFO [Controller 0]: Controller 0 incremented epoch to 6 (kafka.controller.KafkaController)
[2017-11-23 17:15:30,188] INFO [Controller 0]: Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
[2017-11-23 17:15:30,189] INFO [Controller 0]: Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
[2017-11-23 17:15:30,189] INFO [Controller 0]: Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
[2017-11-23 17:15:30,192] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController)
[2017-11-23 17:15:30,193] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController)
[2017-11-23 17:15:30,194] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController)
[2017-11-23 17:15:30,198] INFO [Controller 0]: List of topics to be deleted:  (kafka.controller.KafkaController)
[2017-11-23 17:15:30,198] INFO [Controller 0]: List of topics ineligible for deletion: topic (kafka.controller.KafkaController)
[2017-11-23 17:15:30,201] INFO [Controller 0]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-11-23 17:15:30,202] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-11-23 17:15:30,202] INFO [Controller 0]: Current list of topics in the cluster: Set(topic) (kafka.controller.KafkaController)
[2017-11-23 17:15:30,206] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map([Topic=topic,Partition=0,Replica=0] -> ReplicaDeletionIneligible) (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:15:30,224] DEBUG [OfflinePartitionLeaderSelector]: No broker in ISR is alive for [topic,0]. Pick the leader from the alive assigned replicas:  (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:15:30,231] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map([topic,0] -> OfflinePartition) (kafka.controller.PartitionStateMachine)
[2017-11-23 17:15:30,234] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 6 (kafka.controller.KafkaController)
[2017-11-23 17:15:30,235] INFO [Controller 0]: Starting preferred replica leader election for partitions  (kafka.controller.KafkaController)
[2017-11-23 17:15:30,236] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions  (kafka.controller.PartitionStateMachine)
[2017-11-23 17:15:30,244] INFO [Controller 0]: starting the partition rebalance scheduler (kafka.controller.KafkaController)
[2017-11-23 17:15:30,246] INFO [Controller 0]: Controller startup complete (kafka.controller.KafkaController)
[2017-11-23 17:15:30,264] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:15:30,280] INFO [delete-topics-thread-0], Starting  (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:15:30,283] DEBUG [Topic Deletion Manager 0], Waiting for signal to start or continue topic deletion (kafka.controller.TopicDeletionManager)
[2017-11-23 17:15:30,324] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
[2017-11-23 17:15:30,325] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager)
[2017-11-23 17:15:30,330] INFO [Controller-0-to-broker-0-send-thread], Controller 0 connected to id:0,host:silvio-VirtualBox,port:9092 for sending state change requests (kafka.controller.RequestSendThread)
[2017-11-23 17:15:30,334] INFO [Controller 0]: New broker startup callback for 0 (kafka.controller.KafkaController)
[2017-11-23 17:15:30,341] INFO [Controller-0-to-broker-0-send-thread], Starting  (kafka.controller.RequestSendThread)
[2017-11-23 17:15:30,343] INFO [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=topic,Partition=0,Replica=0] (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:15:30,367] DEBUG [OfflinePartitionLeaderSelector]: Some broker in ISR is alive for [topic,0]. Select 0 from ISR 0 to be the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:15:30,370] INFO [OfflinePartitionLeaderSelector]: Selected new leader and ISR {"leader":0,"leader_epoch":4,"isr":[0]} for offline partition [topic,0] (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-23 17:15:30,381] DEBUG [Partition state machine on Controller 0]: After leader election, leader cache is updated to Map([topic,0] -> (Leader:0,ISR:0,LeaderEpoch:4,ControllerEpoch:6)) (kafka.controller.PartitionStateMachine)
[2017-11-23 17:15:35,246] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
[2017-11-23 17:15:35,249] DEBUG [Controller 0]: preferred replicas by broker Map(0 -> Map([topic,0] -> List(0))) (kafka.controller.KafkaController)
[2017-11-23 17:15:35,251] DEBUG [Controller 0]: topics not in preferred replica Map() (kafka.controller.KafkaController)
[2017-11-23 17:15:35,252] TRACE [Controller 0]: leader imbalance ratio for broker 0 is 0,000000 (kafka.controller.KafkaController)
[2017-11-23 17:20:35,245] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
[2017-11-23 17:20:35,245] DEBUG [Controller 0]: preferred replicas by broker Map(0 -> Map([topic,0] -> List(0))) (kafka.controller.KafkaController)
[2017-11-23 17:20:35,245] DEBUG [Controller 0]: topics not in preferred replica Map() (kafka.controller.KafkaController)
[2017-11-23 17:20:35,245] TRACE [Controller 0]: leader imbalance ratio for broker 0 is 0,000000 (kafka.controller.KafkaController)
[2017-11-23 17:23:30,114] INFO [Controller 0]: Shutting down broker 0 (kafka.controller.KafkaController)
[2017-11-23 17:23:30,115] DEBUG [Controller 0]: All shutting down brokers: 0 (kafka.controller.KafkaController)
[2017-11-23 17:23:30,115] DEBUG [Controller 0]: Live brokers:  (kafka.controller.KafkaController)
[2017-11-23 17:23:30,123] TRACE [Controller 0]: All leaders = [topic,0] -> (Leader:0,ISR:0,LeaderEpoch:4,ControllerEpoch:6) (kafka.controller.KafkaController)
[2017-11-23 17:23:30,465] INFO [delete-topics-thread-0], Shutting down (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:23:30,466] INFO [delete-topics-thread-0], Stopped  (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:23:30,466] INFO [delete-topics-thread-0], Shutdown completed (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
[2017-11-23 17:23:30,467] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
[2017-11-23 17:23:30,467] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
[2017-11-23 17:23:30,468] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread)
[2017-11-23 17:23:30,468] INFO [Controller-0-to-broker-0-send-thread], Stopped  (kafka.controller.RequestSendThread)
[2017-11-23 17:23:30,468] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread)