[kafka] branch trunk updated: HOTFIX: decrease session timeout in flaky NamedTopologyIntegrationTest (#11259)

[ableegoldman]

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

ableegoldman 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 53277a9  HOTFIX: decrease session timeout in flaky 
NamedTopologyIntegrationTest (#11259)
53277a9 is described below

commit 53277a92a691aefe779e2d2663590581c7db167c
Author: A. Sophie Blee-Goldman <sop...@confluent.io>
AuthorDate: Wed Aug 25 21:52:32 2021 -0700

    HOTFIX: decrease session timeout in flaky NamedTopologyIntegrationTest 
(#11259)
    
    Decrease session timeout back to 10s to improve test flakiness
    
    Reviewers: Walker Carlson <wcarl...@confluent.io>
---
 .../apache/kafka/streams/integration/NamedTopologyIntegrationTest.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
index 7f4f2ad..2b01fee 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
@@ -167,6 +167,7 @@ public class NamedTopologyIntegrationTest {
         streamsConfiguration.put(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 2);
         streamsConfiguration.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 
1000L);
         streamsConfiguration.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, 
"earliest");
+        streamsConfiguration.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 10 
* 1000);
         return streamsConfiguration;
     }