You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/06/05 12:44:59 UTC
kafka git commit: MINOR: Default GroupInitialRebalanceDelayMsProp to
0 and OffsetsTopicPartitionsProp to 5 in tests
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 <is...@juma.me.uk>
Reviewers: Damian Guy <da...@gmail.com>, Rajini Sivaram <ra...@googlemail.com>
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 <is...@juma.me.uk>
Authored: Mon Jun 5 13:43:29 2017 +0100
Committer: Ismael Juma <is...@juma.me.uk>
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) })