diff --git a/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java b/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java index 0e8eb6b..21e64ca 100644 --- a/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java +++ b/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java @@ -36,6 +36,7 @@ public class RepartitionTopicConfig extends InternalTopicConfig { tempTopicDefaultOverrides.put(TopicConfig.SEGMENT_INDEX_BYTES_CONFIG, "52428800"); // 50 MB tempTopicDefaultOverrides.put(TopicConfig.SEGMENT_BYTES_CONFIG, "52428800"); // 50 MB tempTopicDefaultOverrides.put(TopicConfig.SEGMENT_MS_CONFIG, "600000"); // 10 min + tempTopicDefaultOverrides.put(TopicConfig.RETENTION_MS_CONFIG, "-1"); // Infinite REPARTITION_TOPIC_DEFAULT_OVERRIDES = Collections.unmodifiableMap(tempTopicDefaultOverrides); }