[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-0 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-11 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-13 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-16 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-10 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-5 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-16 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-19 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-8 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-10 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-2 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-7 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-18 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-2 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-13 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-12 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-7 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-18 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-5 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-10 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-4 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-15 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-15 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-4 (state.change.logger)
[2017-07-12 16:04:28,016] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-9 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-1 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-7 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-18 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-17 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-6 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-12 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-1 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-17 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-6 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-15 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-4 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-9 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-14 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-9 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-3 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-14 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-3 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-12 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-1 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-19 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-0 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-6 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-11 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-17 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-11 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-16 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-5 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-0 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-14 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-3 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-8 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-13 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-19 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-8 (state.change.logger)
[2017-07-12 16:04:28,017] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-2 (state.change.logger)
[2017-07-12 16:04:28,395] TRACE Controller 1001 epoch 12 received response {error_code=31} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:28,482] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,3] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,648] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,7] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,696] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,2] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,731] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,0] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,769] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,18] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,786] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,1] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,796] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,4] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,807] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,12] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,821] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,17] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,824] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,15] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,827] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,14] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,830] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,8] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,832] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,6] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,835] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,19] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,837] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,13] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,860] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,5] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:28,940] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,11] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,078] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,10] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,090] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,16] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,102] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,9] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,3] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,7] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,2] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,0] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,18] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,1] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,4] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,12] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,17] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,15] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,14] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,8] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,6] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,19] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,103] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,13] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,104] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,5] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,104] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,11] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,104] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,10] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,104] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,16] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,104] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,9] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:04:29,104] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=3,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,105] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=7,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,105] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=2,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,105] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=0,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,106] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=18,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,107] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=1,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,107] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=4,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,108] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=12,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,108] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=17,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,108] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=15,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,109] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=14,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,109] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=8,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,109] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=6,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,110] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=19,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,110] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=13,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,111] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=5,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,112] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=11,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,113] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=10,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,114] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=16,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,114] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=9,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,115] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=3,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,115] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,3] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,116] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=7,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,118] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,7] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,120] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=2,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,120] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,2] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,124] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=0,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,125] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,0] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,126] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=18,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,127] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,18] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,130] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=1,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,130] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,1] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,134] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=4,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,135] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,4] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,136] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=12,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,137] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,12] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,137] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=17,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,137] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,17] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,138] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=15,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,138] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,15] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,140] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=14,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,141] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,14] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,151] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=8,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,154] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,8] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,163] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=6,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,164] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,6] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,166] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=19,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,167] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,19] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,170] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=13,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,173] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,13] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,174] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=5,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,174] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,5] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,174] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=11,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,175] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,11] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,175] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=10,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,176] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,10] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,176] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=16,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,176] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,16] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,177] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=9,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,178] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,9] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:04:29,182] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,10] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,352] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,1] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,354] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,12] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,393] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,17] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,394] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,3] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,405] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,4] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,410] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,2] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,411] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,15] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,412] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,7] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,412] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,11] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,413] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,18] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,414] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,19] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,415] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,9] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,416] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,13] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,416] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,0] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,417] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,6] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,418] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,14] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,419] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,5] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,420] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,8] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,421] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test-kafka-topic,16] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:04:29,422] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=10,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,422] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=1,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,422] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=12,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,423] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=17,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,423] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=3,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,428] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=4,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,428] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=2,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,428] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=15,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,429] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=7,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,429] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=11,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,430] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=18,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,430] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=19,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,431] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=9,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,431] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=13,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,431] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=0,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,432] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=6,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,432] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=14,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,432] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=5,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,433] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=8,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:04:29,433] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test-kafka-topic,partition=16,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:19:52,770] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,7] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,12] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,18] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,6] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,3] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,2] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,5] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,10] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,15] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,19] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,13] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,1] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,0] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,14] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,4] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,8] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,11] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,9] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,17] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,795] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,16] state from NonExistentPartition to NewPartition with assigned replicas 1001 (state.change.logger)
[2017-07-12 16:19:52,826] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,12] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,832] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,16] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,832] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,9] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,833] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,2] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,833] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,7] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,833] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,14] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,834] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,3] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,834] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,11] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,834] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,13] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,834] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,5] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,835] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,19] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,835] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,17] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,835] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,8] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,836] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,6] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,836] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,10] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,836] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,4] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,836] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,1] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,837] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,15] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,837] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,18] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,837] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,0] from NonExistentReplica to NewReplica (state.change.logger)
[2017-07-12 16:19:52,861] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,7] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:52,865] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,12] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:52,895] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,18] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,010] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,6] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,013] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,3] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,017] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,2] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,020] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,5] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,023] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,10] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,027] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,15] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,030] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,19] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,033] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,13] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,036] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,1] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,039] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,0] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,042] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,14] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,046] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,4] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,182] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,8] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,288] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,11] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,292] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,9] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,295] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,17] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 changed partition [test1-kafka-topic,16] from NewPartition to OnlinePartition with leader 1001 (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,9] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,14] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,3] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,6] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,0] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,11] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,8] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,19] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,16] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,5] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,10] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,2] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,13] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,7] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,18] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,15] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,4] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,1] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,12] (state.change.logger)
[2017-07-12 16:19:53,299] TRACE Controller 1001 epoch 12 sending become-leader LeaderAndIsr request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition [test1-kafka-topic,17] (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-9 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-0 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-11 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-13 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-16 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-10 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-14 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-5 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-3 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-16 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-6 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-19 (state.change.logger)
[2017-07-12 16:19:53,322] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-8 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-10 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-2 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-0 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-7 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-18 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-2 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-11 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-13 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-12 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-7 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-18 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-5 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-10 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-4 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-15 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-8 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-19 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-15 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-4 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-9 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-1 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-7 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-16 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-5 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-18 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-10 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-17 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-6 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-12 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-1 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-17 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-6 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-13 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-2 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-15 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-4 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-9 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-14 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-9 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-18 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-7 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-3 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-14 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-3 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-12 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-1 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-19 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-15 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-4 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-0 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-6 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-11 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-17 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-11 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-16 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-5 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-0 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-1 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-14 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-3 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-12 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-8 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:1001,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-17 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-13 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-19 (state.change.logger)
[2017-07-12 16:19:53,323] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-8 (state.change.logger)
[2017-07-12 16:19:53,324] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-2 (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,12] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,16] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,9] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,2] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,7] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,14] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,3] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,11] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,13] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,5] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,19] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,17] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,343] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,8] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,344] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,6] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,344] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,10] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,344] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,4] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,344] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,1] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,344] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,15] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,344] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,18] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,344] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,0] from NewReplica to OnlineReplica (state.change.logger)
[2017-07-12 16:19:53,660] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=4,error_code=31},{topic=test1-kafka-topic,partition=16,error_code=31},{topic=test1-kafka-topic,partition=8,error_code=31},{topic=test1-kafka-topic,partition=0,error_code=31},{topic=test1-kafka-topic,partition=12,error_code=31},{topic=test1-kafka-topic,partition=17,error_code=31},{topic=test1-kafka-topic,partition=5,error_code=31},{topic=test1-kafka-topic,partition=9,error_code=31},{topic=test1-kafka-topic,partition=18,error_code=31},{topic=test1-kafka-topic,partition=2,error_code=31},{topic=test1-kafka-topic,partition=11,error_code=31},{topic=test1-kafka-topic,partition=13,error_code=31},{topic=test1-kafka-topic,partition=19,error_code=31},{topic=test1-kafka-topic,partition=14,error_code=31},{topic=test1-kafka-topic,partition=6,error_code=31},{topic=test1-kafka-topic,partition=1,error_code=31},{topic=test1-kafka-topic,partition=10,error_code=31},{topic=test1-kafka-topic,partition=7,error_code=31},{topic=test1-kafka-topic,partition=3,error_code=31},{topic=test1-kafka-topic,partition=15,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:19:53,660] TRACE Controller 1001 epoch 12 received response {error_code=31} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:13,744] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-9 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-0 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-11 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-13 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-16 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-10 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-5 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-14 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-3 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-16 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-6 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-19 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-10 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-8 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-2 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-0 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-7 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-18 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-2 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-11 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-13 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-12 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-7 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-18 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-5 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-10 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-15 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-4 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-8 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-19 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-15 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-4 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-9 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-1 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-7 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-5 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-16 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-18 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-10 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-6 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-17 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-12 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-1 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-17 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-6 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-13 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-2 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-4 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-15 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-9 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-14 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-9 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-7 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-3 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-18 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-3 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-14 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-12 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-1 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-19 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-15 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-4 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-17 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-6 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-0 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-11 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-11 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-16 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-5 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-0 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-1 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-14 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary01-topic-3 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-12 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-8 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:1001,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test1-kafka-topic-17 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-13 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-8 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition test-kafka-topic-19 (state.change.logger)
[2017-07-12 16:20:13,745] TRACE Controller 1001 epoch 12 sending UpdateMetadata request (Leader:-2,ISR:,LeaderEpoch:0,ControllerEpoch:12) to broker 1001 for partition istuary011-topic-2 (state.change.logger)
[2017-07-12 16:20:13,746] TRACE Controller 1001 epoch 12 received response {error_code=31} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:13,833] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,12] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,375] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,16] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,405] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,9] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,408] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,2] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,410] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,7] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,414] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,14] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,416] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,3] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,419] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,11] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,422] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,13] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,424] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,5] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,426] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,19] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,428] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,17] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,433] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,8] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,435] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,6] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,437] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,10] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,439] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,4] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,442] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,1] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,444] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,15] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,445] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,18] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,0] from OnlineReplica to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,12] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,16] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,9] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,2] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,7] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,14] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,3] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,11] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,13] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,5] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,19] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,17] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,8] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,6] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,10] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,4] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,1] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,15] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,18] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,448] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,0] from OfflineReplica to ReplicaDeletionStarted (state.change.logger)
[2017-07-12 16:20:14,450] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=12,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,451] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=16,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,451] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=9,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,452] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=2,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,452] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=7,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,452] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=14,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,453] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=3,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,453] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=11,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,453] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=13,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,454] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=5,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,454] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=19,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,454] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=17,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,455] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=8,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,455] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=6,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,455] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=10,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,456] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=4,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,456] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=1,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,456] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=15,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,457] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=18,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,457] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=0,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,457] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=12,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,458] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,12] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,458] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=16,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,460] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,16] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,465] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=9,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,465] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,9] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,467] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=2,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,468] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,2] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,469] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=7,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,469] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,7] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,470] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=14,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,472] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,14] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,473] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=3,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,475] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,3] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,477] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=11,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,478] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,11] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,478] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=13,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,503] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,13] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,504] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=5,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,505] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,5] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,506] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=19,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,508] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,19] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,510] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=17,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,511] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,17] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,511] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=8,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,512] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,8] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,512] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=6,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,514] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,6] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,514] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=10,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,515] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,10] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,516] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=4,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,516] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,4] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,516] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=1,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,518] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,1] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,518] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=15,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,524] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,15] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,525] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=18,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,526] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,18] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,527] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=0,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,527] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,0] from ReplicaDeletionStarted to ReplicaDeletionIneligible (state.change.logger)
[2017-07-12 16:20:14,529] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,7] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,530] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,17] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,530] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,19] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,531] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,0] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,533] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,15] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,533] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,10] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,534] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,5] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,535] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,9] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,552] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,14] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,553] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,13] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,553] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,4] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,553] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,16] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,553] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,12] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,553] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,6] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,553] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,1] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,553] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,2] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,559] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,8] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,561] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,18] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,562] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,11] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,562] TRACE Controller 1001 epoch 12 changed state of replica 1001 for partition [test1-kafka-topic,3] from ReplicaDeletionIneligible to OfflineReplica (state.change.logger)
[2017-07-12 16:20:14,563] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=7,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,564] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=17,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,564] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=19,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,565] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=0,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,565] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=15,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,565] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=10,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,566] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=5,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,566] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=9,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,566] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=14,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,567] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=13,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,567] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=4,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,567] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=16,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,568] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=12,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,568] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=6,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,569] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=1,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,569] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=2,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,570] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=8,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,570] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=18,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,570] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=11,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)
[2017-07-12 16:20:14,571] TRACE Controller 1001 epoch 12 received response {error_code=31,partitions=[{topic=test1-kafka-topic,partition=3,error_code=31}]} for a request sent to broker bigdata012.istuary.com:6667 (id: 1001 rack: null) (state.change.logger)