root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

kafka-2016; RollingBounceTest takes long; patched by Ted Malaska; reviewed by Jun Rao

This commit is contained in:
Ted Malaska 2015-04-02 18:20:54 -07:00 committed by Jun Rao
parent 619d78eb52
commit ad722531da
2 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
core/src/test/scala/unit/kafka/integration/RollingBounceTest.scala
View File

@ -40,7 +40,6 @@ class RollingBounceTest extends JUnit3Suite with ZooKeeperTestHarness {
val configProps2 = TestUtils.createBrokerConfig(brokerId2, port2) val configProps2 = TestUtils.createBrokerConfig(brokerId2, port2)
val configProps3 = TestUtils.createBrokerConfig(brokerId3, port3) val configProps3 = TestUtils.createBrokerConfig(brokerId3, port3)
val configProps4 = TestUtils.createBrokerConfig(brokerId4, port4) val configProps4 = TestUtils.createBrokerConfig(brokerId4, port4)
configProps4.put("controlled.shutdown.retry.backoff.ms", "100")
var servers: Seq[KafkaServer] = Seq.empty[KafkaServer] var servers: Seq[KafkaServer] = Seq.empty[KafkaServer]

1
core/src/test/scala/unit/kafka/utils/TestUtils.scala
View File

@ -167,6 +167,7 @@ object TestUtils extends Logging {
props.put("controller.socket.timeout.ms", "1500") props.put("controller.socket.timeout.ms", "1500")
props.put("controlled.shutdown.enable", enableControlledShutdown.toString) props.put("controlled.shutdown.enable", enableControlledShutdown.toString)
props.put("delete.topic.enable", enableDeleteTopic.toString) props.put("delete.topic.enable", enableDeleteTopic.toString)
props.put("controlled.shutdown.retry.backoff.ms", "100")
props props
} }