root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

KAFKA-7484: fix suppression integration tests (#5748) 

Reviewers: Guozhang Wang <guozhang@confluent.io>, Matthias J. Sax <matthias@confluent.io>
This commit is contained in:
John Roesler 2018-10-05 16:12:12 -05:00 committed by Matthias J. Sax
parent 5e9208fc05
commit eb8b1c027a
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionDurabilityIntegrationTest.java
View File

@ -75,7 +75,11 @@ import static org.hamcrest.MatcherAssert.assertThat;
@Category({IntegrationTest.class}) @Category({IntegrationTest.class})
public class SuppressionDurabilityIntegrationTest { public class SuppressionDurabilityIntegrationTest {
@ClassRule @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 StringDeserializer STRING_DESERIALIZER = new StringDeserializer();
private static final StringSerializer STRING_SERIALIZER = new StringSerializer(); private static final StringSerializer STRING_SERIALIZER = new StringSerializer();
private static final Serde<String> STRING_SERDE = Serdes.String(); private static final Serde<String> STRING_SERDE = Serdes.String();

6
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java
View File

@ -75,7 +75,11 @@ import static org.hamcrest.MatcherAssert.assertThat;
@Category({IntegrationTest.class}) @Category({IntegrationTest.class})
public class SuppressionIntegrationTest { public class SuppressionIntegrationTest {
@ClassRule @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 StringDeserializer STRING_DESERIALIZER = new StringDeserializer();
private static final StringSerializer STRING_SERIALIZER = new StringSerializer(); private static final StringSerializer STRING_SERIALIZER = new StringSerializer();
private static final Serde<String> STRING_SERDE = Serdes.String(); private static final Serde<String> STRING_SERDE = Serdes.String();