From 24b03a688f95012d6b2e35390f889bfd465aeacb Mon Sep 17 00:00:00 2001 From: leah Date: Wed, 2 Sep 2020 17:19:39 -0500 Subject: [PATCH] MINOR: Fix message count for sliding windows test (#9248) Reviewers: A. Sophie Blee-Goldman , John Roesler --- .../integration/KStreamAggregationIntegrationTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java index 5cd08f5f86e..e101c2f12c9 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java @@ -484,13 +484,13 @@ public class KStreamAggregationIntegrationTest { new TimeWindowedDeserializer<>(new StringDeserializer(), 500L), new StringDeserializer(), String.class, - 25); + 30); final String resultFromConsoleConsumer = readWindowedKeyedMessagesViaConsoleConsumer( new TimeWindowedDeserializer(), new StringDeserializer(), String.class, - 25, + 30, true); final Comparator, String>> comparator = @@ -587,14 +587,14 @@ public class KStreamAggregationIntegrationTest { new TimeWindowedDeserializer<>(), new IntegerDeserializer(), String.class, - 15); + 30); // read from ConsoleConsumer final String resultFromConsoleConsumer = readWindowedKeyedMessagesViaConsoleConsumer( new TimeWindowedDeserializer(), new IntegerDeserializer(), String.class, - 15, + 30, true); final Comparator, Integer>> comparator =