Repository: kafka Updated Branches: refs/heads/trunk d4a070fcf -> b62f156eb
MINOR: Default GroupInitialRebalanceDelayMsProp to 0 and OffsetsTopicPartitionsProp to 5 in tests This should make tests faster. Tests that require specific values can override these values. Author: Ismael Juma <[email protected]> Reviewers: Damian Guy <[email protected]>, Rajini Sivaram <[email protected]> Closes #3236 from ijuma/default-initial-rebalance-delay-and-offsets-topic-partitions Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b62f156e Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/b62f156e Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/b62f156e Branch: refs/heads/trunk Commit: b62f156eb480498eba338b1746a995ed0d8ce871 Parents: d4a070f Author: Ismael Juma <[email protected]> Authored: Mon Jun 5 13:43:29 2017 +0100 Committer: Ismael Juma <[email protected]> Committed: Mon Jun 5 13:44:37 2017 +0100 ---------------------------------------------------------------------- core/src/test/scala/unit/kafka/utils/TestUtils.scala | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/b62f156e/core/src/test/scala/unit/kafka/utils/TestUtils.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/unit/kafka/utils/TestUtils.scala b/core/src/test/scala/unit/kafka/utils/TestUtils.scala index 60b18d2..14edd35 100755 --- a/core/src/test/scala/unit/kafka/utils/TestUtils.scala +++ b/core/src/test/scala/unit/kafka/utils/TestUtils.scala @@ -239,6 +239,10 @@ object TestUtils extends Logging { props.put(KafkaConfig.LogCleanerDedupeBufferSizeProp, "2097152") props.put(KafkaConfig.LogMessageTimestampDifferenceMaxMsProp, Long.MaxValue.toString) props.put(KafkaConfig.OffsetsTopicReplicationFactorProp, "1") + if (!props.containsKey(KafkaConfig.OffsetsTopicPartitionsProp)) + props.put(KafkaConfig.OffsetsTopicPartitionsProp, "5") + if (!props.containsKey(KafkaConfig.GroupInitialRebalanceDelayMsProp)) + props.put(KafkaConfig.GroupInitialRebalanceDelayMsProp, "0") rack.foreach(props.put(KafkaConfig.RackProp, _)) if (protocolAndPorts.exists { case (protocol, _) => usesSslTransportLayer(protocol) })
