Also including kafka user mailing list. Has anybody seen this error? Any idea to fix it?
Thanks Subhash Agrawal. From: Subhash Agrawal Sent: Wednesday, July 06, 2016 5:12 PM To: 'dev@kafka.apache.org' Subject: Error after restarting kafka broker Hi All, I am running kafka broker (0.10.0 version) in standalone mode (Single kafka broker in the cluster). After couple of restart, I see this error during embedded kafka startup, even though it does not seem to be causing any problem. Is there any way I can avoid this error? Thanks Subhash Agrawal kafka.common.NoReplicaOnlineException: No replica for partition [__consumer_offsets,2] is alive. Live brokers are: [Set()], Assigned replicas are: [List(0)] at kafka.controller.OfflinePartitionLeaderSelector.selectLeader(PartitionLeaderSelector.scala:75) at kafka.controller.PartitionStateMachine.electLeaderForPartition(PartitionStateMachine.scala:345) at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:205) at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:120) at kafka.controller.PartitionStateMachine$$anonfun$triggerOnlinePartitionStateChange$3.apply(PartitionStateMachine.scala:117) at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:733) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:99) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:99) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40) at scala.collection.mutable.HashMap.foreach(HashMap.scala:99) at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:732) at kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:117) at kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:70) at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:335) at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:166) at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:84) at kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:50) at kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:48) at kafka.server.ZookeeperLeaderElector$$anonfun$startup$1.apply(ZookeeperLeaderElector.scala:48) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:231) at kafka.server.ZookeeperLeaderElector.startup(ZookeeperLeaderElector.scala:48) at kafka.controller.KafkaController$$anonfun$startup$1.apply$mcV$sp(KafkaController.scala:684) at kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:680) at kafka.controller.KafkaController$$anonfun$startup$1.apply(KafkaController.scala:680) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:231) at kafka.controller.KafkaController.startup(KafkaController.scala:680) at kafka.server.KafkaServer.startup(KafkaServer.scala:200)