Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

This KIP introduces one new topic configuration item:  remote.log.keeplatest.latest enable
BTW:  topic's remote storage already had some others items such as remote.log.delete.on.disable/remote.log.copy.disable, etc.

...

Code Block
languagejava
titleclients/src/main/java/org/apache/kafka/common/config/TopicConfig.java‎
public static final String REMOTE_LOG_LATEST_ENABLE_CONFIG = "remote.log.latest.enable";
public static final String REMOTE_LOG_LATEST_ENABLE_DOC = "Determines whether to upload all non-active segments to remote storage, including thethose latest onesstill within local retention. " +
            "When set to true (default), all committed segments will be uploaded without checking local retention constraints. " +
            "When set to false, only segments beyond local retention period will be uploaded to remote storage.";

...