HOTFIX: decrease session timeout in flaky NamedTopologyIntegrationTest
Decrease session timeout back to 10s to improve test flakiness
Reviewers: Walker Carlson
@@ -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;
}
