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:12:20 UTC
[kafka] branch trunk 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 trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new eb8b1c0 KAFKA-7484: fix suppression integration tests (#5748)
eb8b1c0 is described below
commit eb8b1c027a610fdf514bcb352613cca2919ed35c
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();