diff --git a/core/src/test/scala/unit/kafka/integration/RollingBounceTest.scala b/core/src/test/scala/unit/kafka/integration/RollingBounceTest.scala index 4d27e41..a6a8d5c 100644 --- a/core/src/test/scala/unit/kafka/integration/RollingBounceTest.scala +++ b/core/src/test/scala/unit/kafka/integration/RollingBounceTest.scala @@ -40,6 +40,9 @@ class RollingBounceTest extends JUnit3Suite with ZooKeeperTestHarness { val configProps2 = TestUtils.createBrokerConfig(brokerId2, port2) val configProps3 = TestUtils.createBrokerConfig(brokerId3, port3) val configProps4 = TestUtils.createBrokerConfig(brokerId4, port4) + configProps1.put("controlled.shutdown.retry.backoff.ms", "100") + configProps2.put("controlled.shutdown.retry.backoff.ms", "100") + configProps3.put("controlled.shutdown.retry.backoff.ms", "100") configProps4.put("controlled.shutdown.retry.backoff.ms", "100") var servers: Seq[KafkaServer] = Seq.empty[KafkaServer]