[kafka] branch trunk updated: MINOR: Fix message count for sliding windows test (#9248)

[vvcephei]

This is an automated email from the ASF dual-hosted git repository.

vvcephei 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 24b03a6  MINOR: Fix message count for sliding windows test (#9248)
24b03a6 is described below

commit 24b03a688f95012d6b2e35390f889bfd465aeacb
Author: leah <ltho...@confluent.io>
AuthorDate: Wed Sep 2 17:19:39 2020 -0500

    MINOR: Fix message count for sliding windows test (#9248)
    
    Reviewers: A. Sophie Blee-Goldman <sop...@confluent.io>, John Roesler 
<vvcep...@apache.org>
---
 .../streams/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 5cd08f5..e101c2f 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<String>(),
                 new StringDeserializer(),
                 String.class,
-                25,
+                30,
                 true);
 
         final Comparator<KeyValueTimestamp<Windowed<String>, 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<String>(),
                 new IntegerDeserializer(),
                 String.class,
-                15,
+                30,
                 true);
 
         final Comparator<KeyValueTimestamp<Windowed<String>, Integer>> 
comparator =