From 935b280540913ade0b2dc1549ba22c4262ee2669 Mon Sep 17 00:00:00 2001 From: Stanislav Kozlovski Date: Tue, 17 Sep 2019 17:43:39 +0100 Subject: [PATCH] MINOR: Default to 5 partitions of the __consumer_offsets topic in Streams integration tests (#7331) Given that the tests do not create clusters larger than 3, we do not gain much by creating 50 partitions for that topic. Reducing it should slightly increase test startup and shutdown speed. Reviewers: Matthias J. Sax , Guozhang Wang , Bill Bejeck --- .../kafka/streams/integration/utils/EmbeddedKafkaCluster.java | 1 + 1 file changed, 1 insertion(+) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java b/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java index d4d2e1c0211..f30ecedc3aa 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java @@ -94,6 +94,7 @@ public class EmbeddedKafkaCluster extends ExternalResource { putIfAbsent(brokerConfig, KafkaConfig$.MODULE$.GroupMinSessionTimeoutMsProp(), 0); putIfAbsent(brokerConfig, KafkaConfig$.MODULE$.GroupInitialRebalanceDelayMsProp(), 0); putIfAbsent(brokerConfig, KafkaConfig$.MODULE$.OffsetsTopicReplicationFactorProp(), (short) 1); + putIfAbsent(brokerConfig, KafkaConfig$.MODULE$.OffsetsTopicPartitionsProp(), 5); putIfAbsent(brokerConfig, KafkaConfig$.MODULE$.AutoCreateTopicsEnableProp(), true); for (int i = 0; i < brokers.length; i++) {