Browse Source

MINOR: Fix message count for sliding windows test (#9248)

Reviewers: A. Sophie Blee-Goldman <sophie@confluent.io>, John Roesler <vvcephei@apache.org>
pull/9249/head
leah 4 years ago committed by GitHub
parent
commit
24b03a688f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 8
      streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java

8
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java

@ -484,13 +484,13 @@ public class KStreamAggregationIntegrationTest { @@ -484,13 +484,13 @@ public class KStreamAggregationIntegrationTest {
new TimeWindowedDeserializer<>(new StringDeserializer(), 500L),
new StringDeserializer(),
String.class,
25);
30);
final String resultFromConsoleConsumer = readWindowedKeyedMessagesViaConsoleConsumer(
new TimeWindowedDeserializer<String>(),
new StringDeserializer(),
String.class,
25,
30,
true);
final Comparator<KeyValueTimestamp<Windowed<String>, String>> comparator =
@ -587,14 +587,14 @@ public class KStreamAggregationIntegrationTest { @@ -587,14 +587,14 @@ public class KStreamAggregationIntegrationTest {
new TimeWindowedDeserializer<>(),
new IntegerDeserializer(),
String.class,
15);
30);
// read from ConsoleConsumer
final String resultFromConsoleConsumer = readWindowedKeyedMessagesViaConsoleConsumer(
new TimeWindowedDeserializer<String>(),
new IntegerDeserializer(),
String.class,
15,
30,
true);
final Comparator<KeyValueTimestamp<Windowed<String>, Integer>> comparator =

Loading…
Cancel
Save