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
Reviewers: Damian Guy Rajini Sivaram
Closes from ijuma/default-initial-rebalance-delay-and-offsets-topic-partitions
@@ -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) })
