Thanks Jun. Hope we could get that in soon On Sat Jan 24 2015 at 上午1:50:57 Jun Rao <j...@confluent.io> wrote:
> Yes, we have already filed https://issues.apache.org/ > jira/browse/KAFKA-1887 > to track this. > > Thanks, > > Jun > > > On Fri, Jan 23, 2015 at 5:30 AM, Manu Zhang <owenzhang1...@gmail.com> > wrote: > > > Hi all, > > > > I've been using KafkaServerTestHarness to integration test my kafka > > application. > > > > All the tests passed but when the server was teared down the error below > > was thrown. > > > > [ERROR] [01/23/2015 16:34:19.118] [logger] Controller 0 epoch 1 initiated > > state change for partition [testTopic844927,0] from OfflinePartition to > > OnlinePartition failed > > kafka.common.NoReplicaOnlineException: No replica for partition > > [testTopic844927,0] 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:357) > > at > > > > kafka.controller.PartitionStateMachine.kafka$controller$ > PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:206) > > 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:778) > > 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:777) > > at > > > > kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateCha > nge(PartitionStateMachine.scala:117) > > at > > kafka.controller.KafkaController.onBrokerFailure( > KafkaController.scala:446) > > at > > > > kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$ > handleChildChange$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp( > ReplicaStateMachine.scala:373) > > at > > > > kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$ > handleChildChange$1$$anonfun$apply$mcV$sp$1.apply( > ReplicaStateMachine.scala:359) > > at > > > > kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$ > handleChildChange$1$$anonfun$apply$mcV$sp$1.apply( > ReplicaStateMachine.scala:359) > > at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) > > at > > > > kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$ > handleChildChange$1.apply$mcV$sp(ReplicaStateMachine.scala:358) > > at > > > > kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$ > handleChildChange$1.apply(ReplicaStateMachine.scala:357) > > at > > > > kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$ > handleChildChange$1.apply(ReplicaStateMachine.scala:357) > > at kafka.utils.Utils$.inLock(Utils.scala:535) > > at > > > > kafka.controller.ReplicaStateMachine$BrokerChangeListener. > handleChildChange(ReplicaStateMachine.scala:356) > > at org.I0Itec.zkclient.ZkClient$7.run(ZkClient.java:568) > > at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71) > > > > The error didn't affect the tests but pollute the log. > > > > Is there a way to avoid this ? > > > > Thanks, > > Manu > > >
