You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2018/10/05 21:13:26 UTC
[kafka] branch 2.1 updated: KAFKA-7484: fix suppression integration
tests (#5748)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.1 by this push:
new 5ad2dc3 KAFKA-7484: fix suppression integration tests (#5748)
5ad2dc3 is described below
commit 5ad2dc36dd71aef04674200ca0afa4188edb54ba
Author: John Roesler <vv...@users.noreply.github.com>
AuthorDate: Fri Oct 5 16:12:12 2018 -0500
KAFKA-7484: fix suppression integration tests (#5748)
Reviewers: Guozhang Wang <gu...@confluent.io>, Matthias J. Sax <ma...@confluent.io>
---
.../streams/integration/SuppressionDurabilityIntegrationTest.java | 6 +++++-
.../kafka/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 93ecc53..c26b52f 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 @@ import static org.hamcrest.MatcherAssert.assertThat;
@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> 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 94bc057..ee32a1d 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 @@ import static org.hamcrest.MatcherAssert.assertThat;
@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> STRING_SERDE = Serdes.String();