[2017-11-25 17:34:17,285] INFO [Controller 1]: Broker 1 starting become controller state transition (kafka.controller.KafkaController)
[2017-11-25 17:34:17,432] INFO [Controller 1]: Initialized controller epoch to 31 and zk version 30 (kafka.controller.KafkaController)
[2017-11-25 17:34:17,434] INFO [Controller 1]: Controller 1 incremented epoch to 32 (kafka.controller.KafkaController)
[2017-11-25 17:34:17,434] DEBUG [Controller 1]: Registering IsrChangeNotificationListener (kafka.controller.KafkaController)
[2017-11-25 17:34:17,524] DEBUG [Channel manager on controller 1]: Controller 1 trying to connect to broker 1 (kafka.controller.ControllerChannelManager)
[2017-11-25 17:34:17,527] INFO [Controller 1]: Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
[2017-11-25 17:34:17,527] INFO [Controller 1]: Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
[2017-11-25 17:34:17,527] INFO [Controller 1]: Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
[2017-11-25 17:34:17,527] INFO [Controller 1]: Partitions being reassigned: Map() (kafka.controller.KafkaController)
[2017-11-25 17:34:17,527] INFO [Controller 1]: Partitions already reassigned: Set() (kafka.controller.KafkaController)
[2017-11-25 17:34:17,527] INFO [Controller 1]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController)
[2017-11-25 17:34:17,528] INFO [Controller 1]: List of topics to be deleted:  (kafka.controller.KafkaController)
[2017-11-25 17:34:17,528] INFO [Controller 1]: List of topics ineligible for deletion: UXPB_ReqQ,NMS_RetryQ,UXPB_ImageQ,NMS_NotifyQ,BPA_BinLogQ,RPT_ReportQ,UXPB_VideoQ,ImageQ,UXPB_ESQ,TMP_RPT_ReportQ (kafka.controller.KafkaController)
[2017-11-25 17:34:17,528] INFO [Controller 1]: Currently active brokers in the cluster: Set(1) (kafka.controller.KafkaController)
[2017-11-25 17:34:17,528] INFO [Controller 1]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
[2017-11-25 17:34:17,528] INFO [Controller 1]: Current list of topics in the cluster: Set(UXPB_ReqQ, NMS_RetryQ, UXPB_ImageQ, NMS_NotifyQ, BPA_BinLogQ, TempBinLogReqQ, RPT_ReportQ, __consumer_offsets, UXPB_VideoQ, Test1, ImageQ, UXPB_ESQ, ESQ, VideoQ, TMP_RPT_ReportQ) (kafka.controller.KafkaController)
s, UXPB_VideoQ, Test1, ImageQ, UXPB_ESQ, ESQ, VideoQ, TMP_RPT_ReportQ) (kafka.controller.KafkaController)
[2017-11-25 17:34:17,528] INFO [Replica state machine on controller 1]: Invoking state change to OnlineReplica for replicas [Topic=NMS_RetryQ,Partition=9,Replica=1],[Topic=__consumer_offsets,Partition=28,Replica=1],[Topic=NMS_RetryQ,Partition=6,Replica=1],[Topic=__consumer_offsets,Partition=48,Replica=1],[Topic=__consumer_offsets,Partition=5,Replica=1],[Topic=VideoQ,Partition=0,Replica=1],[Topic=__consumer_offsets,Partition=21,Replica=1]],[Topic=__consumer_offsets,Partition=24,Replica=1] (kafka.controller.ReplicaStateMachine)
[2017-11-25 17:34:17,535] INFO [Controller-1-to-broker-1-send-thread], Starting  (kafka.controller.RequestSendThread)
[2017-11-25 17:34:17,544] INFO [Controller-1-to-broker-1-send-thread], Controller 1 connected to 10.110.174.82:9092 (id: 1 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
[2017-11-25 17:34:17,559] DEBUG [OfflinePartitionLeaderSelector]: Some broker in ISR is alive for [NMS_NotifyQ,5]. Select 1 from ISR 1 to be the leader. (kafka.controller.OfflinePartitionLeaderSelector)
[2017-11-25 17:34:17,559] INFO [OfflinePartitionLeaderSelector]: Selected new leader and ISR {"leader":1,"leader_epoch":27,"isr":[1]} for offline partition [NMS_NotifyQ,5] (kafka.controller.OfflinePartitionLeaderSelector)
@