HOTFIX: Set session timeout and heartbeat interval to default to decrease flakiness
Set session timeout and heartbeat interval to default for RestoreIntegrationTest
Reviewers: Boyang Chen A. Sophie Blee-Goldman Guozhang Wang
@@ -117,8 +117,6 @@ public class RestoreIntegrationTest {
streamsConfiguration.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.Integer().getClass());
streamsConfiguration.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 1000);
streamsConfiguration.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
- streamsConfiguration.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 1000);
- streamsConfiguration.put(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, 300);
return streamsConfiguration;
}
