From d0f346fd5dd9d84ce0b4fdcbeb95965b16878fc1 Mon Sep 17 00:00:00 2001 From: John Roesler Date: Fri, 5 Oct 2018 12:10:11 -0500 Subject: [PATCH] KAFKA-7484: fix suppression integration tests --- .../integration/SuppressionDurabilityIntegrationTest.java | 6 +++++- .../streams/integration/SuppressionIntegrationTest.java | 6 +++++- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/SuppressionDurabilityIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/SuppressionDurabilityIntegrationTest.java index 93ecc53a7fc6f..c26b52f5a0b81 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/SuppressionDurabilityIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/SuppressionDurabilityIntegrationTest.java @@ -75,7 +75,11 @@ @Category({IntegrationTest.class}) public class SuppressionDurabilityIntegrationTest { @ClassRule - public static final EmbeddedKafkaCluster CLUSTER = new EmbeddedKafkaCluster(3); + public static final EmbeddedKafkaCluster CLUSTER = new EmbeddedKafkaCluster( + 3, + mkProperties(mkMap()), + 0L + ); private static final StringDeserializer STRING_DESERIALIZER = new StringDeserializer(); private static final StringSerializer STRING_SERIALIZER = new StringSerializer(); private static final Serde STRING_SERDE = Serdes.String(); diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java index 94bc0570b0ff0..ee32a1dc371fe 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java @@ -75,7 +75,11 @@ @Category({IntegrationTest.class}) public class SuppressionIntegrationTest { @ClassRule - public static final EmbeddedKafkaCluster CLUSTER = new EmbeddedKafkaCluster(1); + public static final EmbeddedKafkaCluster CLUSTER = new EmbeddedKafkaCluster( + 1, + mkProperties(mkMap()), + 0L + ); private static final StringDeserializer STRING_DESERIALIZER = new StringDeserializer(); private static final StringSerializer STRING_SERIALIZER = new StringSerializer(); private static final Serde STRING_SERDE = Serdes.String();