KAFKA-9295: revert session timeout to default value (apache#10736)

Revert the hard-coded increased session timeout now that the default is 45s Reviewers: Anna Sophie Blee-Goldman <[email protected]>
Mr-J-1210 · Jun 10, 2021 · 8eecb91 · 8eecb91
1 parent 69d5075
commit 8eecb91
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java b/...apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java
@@ -210,8 +210,7 @@ private static Properties getStreamsConfig() {
         streamsConfig.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
         streamsConfig.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
         streamsConfig.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 100L);
-        // increase the session timeout value, to avoid unnecessary rebalance
-        streamsConfig.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 20000);
+
         return streamsConfig;
     }