Ismael Juma created KAFKA-4198: ---------------------------------- Summary: Transient test failure: ConsumerBounceTest.testConsumptionWithBrokerFailures Key: KAFKA-4198 URL: https://issues.apache.org/jira/browse/KAFKA-4198 Project: Kafka Issue Type: Sub-task Reporter: Ismael Juma
The issue seems to be that we call `startup` while `shutdown` is still taking place. {code} java.lang.AssertionError: expected:<107> but was:<0> at org.junit.Assert.fail(Assert.java:88) at org.junit.Assert.failNotEquals(Assert.java:834) at org.junit.Assert.assertEquals(Assert.java:645) at org.junit.Assert.assertEquals(Assert.java:631) at kafka.api.ConsumerBounceTest$$anonfun$consumeWithBrokerFailures$2.apply(ConsumerBounceTest.scala:91) at kafka.api.ConsumerBounceTest$$anonfun$consumeWithBrokerFailures$2.apply(ConsumerBounceTest.scala:90) at scala.collection.Iterator$class.foreach(Iterator.scala:893) at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at kafka.api.ConsumerBounceTest.consumeWithBrokerFailures(ConsumerBounceTest.scala:90) at kafka.api.ConsumerBounceTest.testConsumptionWithBrokerFailures(ConsumerBounceTest.scala:70) {code} {code} java.lang.IllegalStateException: Kafka server is still shutting down, cannot re-start! at kafka.server.KafkaServer.startup(KafkaServer.scala:184) at kafka.integration.KafkaServerTestHarness$$anonfun$restartDeadBrokers$2.apply$mcVI$sp(KafkaServerTestHarness.scala:117) at kafka.integration.KafkaServerTestHarness$$anonfun$restartDeadBrokers$2.apply(KafkaServerTestHarness.scala:116) at kafka.integration.KafkaServerTestHarness$$anonfun$restartDeadBrokers$2.apply(KafkaServerTestHarness.scala:116) at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:733) at scala.collection.immutable.Range.foreach(Range.scala:160) at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:732) at kafka.integration.KafkaServerTestHarness$class.restartDeadBrokers(KafkaServerTestHarness.scala:116) at kafka.api.ConsumerBounceTest.restartDeadBrokers(ConsumerBounceTest.scala:34) at kafka.api.ConsumerBounceTest$BounceBrokerScheduler.doWork(ConsumerBounceTest.scala:158) {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)