[2014-05-16 14:11:52,791] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:52,793] ERROR Controller 0 epoch 45 initiated state change for partition [gk.q.log,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.log,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,794] TRACE Controller 0 epoch 45 started leader election for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:52,796] ERROR Controller 0 epoch 45 initiated state change for partition [gk.t.cluster.response,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.t.cluster.response,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,796] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:52,797] ERROR Controller 0 epoch 45 initiated state change for partition [gk.q.schedule,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.schedule,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,798] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:52,799] ERROR Controller 0 epoch 45 initiated state change for partition [gk.q.log,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.log,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,799] TRACE Controller 0 epoch 45 started leader election for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:52,800] ERROR Controller 0 epoch 45 initiated state change for partition [gk.t.cluster.response,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.t.cluster.response,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,801] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:52,803] ERROR Controller 0 epoch 45 initiated state change for partition [gk.q.module,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.module,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,803] TRACE Controller 0 epoch 45 started leader election for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:52,804] ERROR Controller 0 epoch 45 initiated state change for partition [gk.t.cluster.request,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.t.cluster.request,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,805] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:52,806] ERROR Controller 0 epoch 45 initiated state change for partition [gk.q.module,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.module,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,806] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:52,808] ERROR Controller 0 epoch 45 initiated state change for partition [gk.q.schedule,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.schedule,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,808] TRACE Controller 0 epoch 45 started leader election for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:52,809] ERROR Controller 0 epoch 45 initiated state change for partition [gk.t.cluster.request,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.t.cluster.request,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1066)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1066)
	at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:52,848] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44) with correlationId 234 to broker 0 for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:52,849] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.q.module,0] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,849] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.response,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,849] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.q.schedule,1] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,849] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.response,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,849] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.q.module,1] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,849] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.request,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.q.schedule,0] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.log,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.q.log,1] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.module,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.t.cluster.response,0] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.module,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.t.cluster.response,1] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.log,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.t.cluster.request,0] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.schedule,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.t.cluster.request,1] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.schedule,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Controller 0 epoch 45 changed state of replica 0 for partition [gk.q.log,0] from ReplicaDeletionIneligible to OnlineReplica (state.change.logger)
[2014-05-16 14:11:52,850] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.request,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 234 (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:52,851] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:52,852] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:52,852] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:52,852] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:52,852] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:52,852] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:52,852] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:52,852] TRACE Controller 0 epoch 45 received response correlationId 234 for a request sent to broker id:0,host:dev,port:9092 (state.change.logger)
[2014-05-16 14:11:52,852] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44) with correlationId 235 to broker 0 for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:52,852] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:52,872] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:52,873] TRACE Controller 0 epoch 45 changed partition [gk.q.log,1] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:52,873] TRACE Controller 0 epoch 45 started leader election for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:52,892] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:52,892] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:52,892] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:52,892] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:52,893] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:52,893] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:52,893] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:52,893] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:52,893] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:52,893] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) correlation id 235 from controller 0 epoch 45 for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:52,893] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 35 for partition [gk.t.cluster.response,0], current leader epoch is 35 (state.change.logger)
[2014-05-16 14:11:52,893] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 34 for partition [gk.t.cluster.response,1], current leader epoch is 34 (state.change.logger)
[2014-05-16 14:11:52,893] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 34 for partition [gk.t.cluster.request,1], current leader epoch is 34 (state.change.logger)
[2014-05-16 14:11:52,893] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 34 for partition [gk.q.log,0], current leader epoch is 34 (state.change.logger)
[2014-05-16 14:11:52,893] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 34 for partition [gk.q.module,1], current leader epoch is 34 (state.change.logger)
[2014-05-16 14:11:52,893] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 33 for partition [gk.q.module,0], current leader epoch is 33 (state.change.logger)
[2014-05-16 14:11:52,893] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 34 for partition [gk.q.log,1], current leader epoch is 34 (state.change.logger)
[2014-05-16 14:11:52,894] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 35 for partition [gk.q.schedule,0], current leader epoch is 35 (state.change.logger)
[2014-05-16 14:11:52,894] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 33 for partition [gk.q.schedule,1], current leader epoch is 33 (state.change.logger)
[2014-05-16 14:11:52,894] WARN Broker 0 received invalid LeaderAndIsr request with correlation id 235 from controller 0 epoch 45 with an older leader epoch 33 for partition [gk.t.cluster.request,0], current leader epoch is 33 (state.change.logger)
[2014-05-16 14:11:52,894] TRACE Controller 0 epoch 45 received response correlationId 235 for a request sent to broker id:0,host:dev,port:9092 (state.change.logger)
[2014-05-16 14:11:52,894] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.response,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,894] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.response,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,894] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.request,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,895] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.log,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,895] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.module,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,895] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.module,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,895] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.log,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,895] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.schedule,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,895] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.schedule,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,895] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:33,ControllerEpoch:44),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.request,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 235 (state.change.logger)
[2014-05-16 14:11:52,895] TRACE Controller 0 epoch 45 received response correlationId 235 for a request sent to broker id:0,host:dev,port:9092 (state.change.logger)
[2014-05-16 14:11:53,031] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:53,032] TRACE Controller 0 epoch 45 changed partition [gk.t.cluster.response,0] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:53,032] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:53,063] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:53,064] TRACE Controller 0 epoch 45 changed partition [gk.q.schedule,0] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:53,064] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:53,071] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:53,072] TRACE Controller 0 epoch 45 changed partition [gk.q.log,0] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:53,072] TRACE Controller 0 epoch 45 started leader election for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:53,080] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:53,080] TRACE Controller 0 epoch 45 changed partition [gk.t.cluster.response,1] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:53,080] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:53,088] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:53,088] TRACE Controller 0 epoch 45 changed partition [gk.q.module,1] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:53,088] TRACE Controller 0 epoch 45 started leader election for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:53,096] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:53,097] TRACE Controller 0 epoch 45 changed partition [gk.t.cluster.request,0] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:53,097] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:53,289] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:53,290] TRACE Controller 0 epoch 45 changed partition [gk.q.module,0] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:53,290] TRACE Controller 0 epoch 45 started leader election for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:53,630] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:53,630] TRACE Controller 0 epoch 45 changed partition [gk.q.schedule,1] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:53,630] TRACE Controller 0 epoch 45 started leader election for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:53,655] TRACE Controller 0 epoch 45 elected leader 0 for Offline partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:53,655] TRACE Controller 0 epoch 45 changed partition [gk.t.cluster.request,1] from OfflinePartition to OnlinePartition with leader 0 (state.change.logger)
[2014-05-16 14:11:53,655] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:36,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:53,655] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:53,655] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:53,655] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:53,655] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:36,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending become-leader LeaderAndIsr request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:36,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:53,656] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:36,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:36,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Controller 0 epoch 45 sending UpdateMetadata request (Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45) with correlationId 236 to broker 0 for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:53,657] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:53,658] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:36,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:53,658] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:53,658] TRACE Broker 0 received LeaderAndIsr request (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) correlation id 236 from controller 0 epoch 45 for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:53,658] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:53,658] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:53,658] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:53,658] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:53,659] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:53,659] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:53,659] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:53,659] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:53,659] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:53,659] TRACE Broker 0 handling LeaderAndIsr request correlationId 236 from controller 0 epoch 45 starting the become-leader transition for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:53,659] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:53,660] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:53,660] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:53,660] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:53,660] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:53,660] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:53,660] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:53,660] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:53,660] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:53,660] TRACE Broker 0 stopped fetchers as part of become-leader request from controller 0 epoch 45 with correlation id 236 for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:11:53,663] TRACE Broker 0 completed LeaderAndIsr request correlationId 236 from controller 0 epoch 45 for the become-leader transition for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:11:53,664] TRACE Controller 0 epoch 45 received response correlationId 236 for a request sent to broker id:0,host:dev,port:9092 (state.change.logger)
[2014-05-16 14:11:53,664] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:36,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.response,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,664] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.response,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,664] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.request,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,664] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.log,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,664] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.module,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,665] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.module,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,665] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:35,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.log,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,665] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:36,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.schedule,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,665] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.q.schedule,1] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,665] TRACE Broker 0 cached leader info (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:34,ControllerEpoch:45),ReplicationFactor:1),AllReplicas:0) for partition [gk.t.cluster.request,0] in response to UpdateMetadata request sent by controller 0 epoch 45 with correlation id 236 (state.change.logger)
[2014-05-16 14:11:53,665] TRACE Controller 0 epoch 45 received response correlationId 236 for a request sent to broker id:0,host:dev,port:9092 (state.change.logger)
[2014-05-16 14:12:21,520] TRACE Controller 0 epoch 46 started leader election for partition [gk.q.log,1] (state.change.logger)
[2014-05-16 14:12:21,521] ERROR Controller 0 epoch 46 initiated state change for partition [gk.q.log,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.log,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:12:21,521] TRACE Controller 0 epoch 46 started leader election for partition [gk.t.cluster.response,0] (state.change.logger)
[2014-05-16 14:12:21,522] ERROR Controller 0 epoch 46 initiated state change for partition [gk.t.cluster.response,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.t.cluster.response,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:12:21,522] TRACE Controller 0 epoch 46 started leader election for partition [gk.q.schedule,0] (state.change.logger)
[2014-05-16 14:12:21,523] ERROR Controller 0 epoch 46 initiated state change for partition [gk.q.schedule,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.schedule,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:12:21,523] TRACE Controller 0 epoch 46 started leader election for partition [gk.q.log,0] (state.change.logger)
[2014-05-16 14:12:21,525] ERROR Controller 0 epoch 46 initiated state change for partition [gk.q.log,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.log,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:12:21,525] TRACE Controller 0 epoch 46 started leader election for partition [gk.t.cluster.response,1] (state.change.logger)
[2014-05-16 14:12:21,526] ERROR Controller 0 epoch 46 initiated state change for partition [gk.t.cluster.response,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.t.cluster.response,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:12:21,526] TRACE Controller 0 epoch 46 started leader election for partition [gk.q.module,1] (state.change.logger)
[2014-05-16 14:12:21,527] ERROR Controller 0 epoch 46 initiated state change for partition [gk.q.module,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.module,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:12:21,527] TRACE Controller 0 epoch 46 started leader election for partition [gk.t.cluster.request,0] (state.change.logger)
[2014-05-16 14:12:21,528] ERROR Controller 0 epoch 46 initiated state change for partition [gk.t.cluster.request,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.t.cluster.request,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:12:21,528] TRACE Controller 0 epoch 46 started leader election for partition [gk.q.module,0] (state.change.logger)
[2014-05-16 14:12:21,529] ERROR Controller 0 epoch 46 initiated state change for partition [gk.q.module,0] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.module,0] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:12:21,530] TRACE Controller 0 epoch 46 started leader election for partition [gk.q.schedule,1] (state.change.logger)
[2014-05-16 14:12:21,531] ERROR Controller 0 epoch 46 initiated state change for partition [gk.q.schedule,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.q.schedule,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
[2014-05-16 14:12:21,531] TRACE Controller 0 epoch 46 started leader election for partition [gk.t.cluster.request,1] (state.change.logger)
[2014-05-16 14:12:21,532] ERROR Controller 0 epoch 46 initiated state change for partition [gk.t.cluster.request,1] from OfflinePartition to OnlinePartition failed (state.change.logger)
kafka.common.NoReplicaOnlineException: No replica for partition [gk.t.cluster.request,1] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)]
	at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:61)
	at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:336)
	at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:185)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:99)
	at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:96)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:743)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:95)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:742)
	at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:96)
	at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:68)
	at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:312)
	at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:162)
	at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
	at kafka.utils.Utils$.inLock(Utils.scala:538)
	at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
	at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)