From 6c54d4cd9e395764f4e9d9055ce6f45783e0496b Mon Sep 17 00:00:00 2001 From: Jian Date: Sun, 24 May 2026 21:52:14 +0800 Subject: [PATCH 1/6] MINOR:MINOR: Narrow remote copy lag validator props to Map Signed-off-by: Jian --- .../org/apache/kafka/storage/internals/log/LogConfig.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java b/storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java index c1a6361e50db1..97246fc07ef0b 100644 --- a/storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java +++ b/storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java @@ -631,7 +631,7 @@ private static void validateRemoteStorageRetentionTime(Map props) { } } - private static void validateRemoteCopyLagTime(Map props) { + private static void validateRemoteCopyLagTime(Map props) { Long retentionMs = (Long) props.get(TopicConfig.RETENTION_MS_CONFIG); Long localRetentionMs = (Long) props.get(TopicConfig.LOCAL_LOG_RETENTION_MS_CONFIG); Long remoteCopyLagMs = (Long) props.get(TopicConfig.REMOTE_COPY_LAG_MS_CONFIG); @@ -644,7 +644,7 @@ private static void validateRemoteCopyLagTime(Map props) { } } - private static void validateRemoteCopyLagSize(Map props) { + private static void validateRemoteCopyLagSize(Map props) { Long retentionBytes = (Long) props.get(TopicConfig.RETENTION_BYTES_CONFIG); Long localRetentionBytes = (Long) props.get(TopicConfig.LOCAL_LOG_RETENTION_BYTES_CONFIG); Long remoteCopyLagBytes = (Long) props.get(TopicConfig.REMOTE_COPY_LAG_BYTES_CONFIG); From 6327e6f7a1bc5e4b1270bb897846379fe898dd80 Mon Sep 17 00:00:00 2001 From: Jian Date: Sun, 24 May 2026 23:59:24 +0800 Subject: [PATCH 2/6] MINOR:Update upgrade document for KIP-1241 Signed-off-by: Jian --- docs/getting-started/upgrade.md | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/docs/getting-started/upgrade.md b/docs/getting-started/upgrade.md index 145960a483a67..db29a4c2a33b0 100644 --- a/docs/getting-started/upgrade.md +++ b/docs/getting-started/upgrade.md @@ -33,7 +33,8 @@ type: docs ### Notable changes in 4.4.0 * The `ClientQuotaCallback#updateClusterMetadata` method is deprecated and will be removed in Kafka 5.0. Custom implementations of `ClientQuotaCallback` no longer need to override this method, as a default no-op implementation is now provided. For further details, please refer to [KIP-1200](https://cwiki.apache.org/confluence/x/axBJFg). - * The in-memory keystores (used for PEM certificates) now use the default type provided by `KeyStore.getDefaultType()` instead of the hardcoded PKCS12 type. + * New configs have been introduced: remote.copy.lag.bytes, remote.copy.lag.ms and their corresponding broker-level configurations. They allow tiered storage redundancy reduced with delayed upload. For further details, please refer to [KIP-1241](https://cwiki.apache.org/confluence/x/A4LMFw). + * The in-memory keystores (used for PEM certificates) now use the default type provided by `KeyStore.getDefaultType()` instead of the hardcoded PKCS12 type. ## Upgrading to 4.3.0 From 2b4e796d013d3eb2b5ebd712157aae8bb04fbf2a Mon Sep 17 00:00:00 2001 From: Jian Date: Mon, 25 May 2026 00:01:31 +0800 Subject: [PATCH 3/6] MINOR: Update upgrade document for KIP-1241 Signed-off-by: Jian --- docs/getting-started/upgrade.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/getting-started/upgrade.md b/docs/getting-started/upgrade.md index db29a4c2a33b0..6ce3bfae5b9bc 100644 --- a/docs/getting-started/upgrade.md +++ b/docs/getting-started/upgrade.md @@ -33,8 +33,8 @@ type: docs ### Notable changes in 4.4.0 * The `ClientQuotaCallback#updateClusterMetadata` method is deprecated and will be removed in Kafka 5.0. Custom implementations of `ClientQuotaCallback` no longer need to override this method, as a default no-op implementation is now provided. For further details, please refer to [KIP-1200](https://cwiki.apache.org/confluence/x/axBJFg). - * New configs have been introduced: remote.copy.lag.bytes, remote.copy.lag.ms and their corresponding broker-level configurations. They allow tiered storage redundancy reduced with delayed upload. For further details, please refer to [KIP-1241](https://cwiki.apache.org/confluence/x/A4LMFw). * The in-memory keystores (used for PEM certificates) now use the default type provided by `KeyStore.getDefaultType()` instead of the hardcoded PKCS12 type. + * New configs have been introduced: remote.copy.lag.bytes, remote.copy.lag.ms and their corresponding broker-level configurations. They allow tiered storage redundancy reduced with delayed upload. For further details, please refer to [KIP-1241](https://cwiki.apache.org/confluence/x/A4LMFw). ## Upgrading to 4.3.0 From 21e1521a826d78a72f741330b01be0b40563b386 Mon Sep 17 00:00:00 2001 From: Jian Date: Mon, 25 May 2026 00:03:07 +0800 Subject: [PATCH 4/6] Revert "MINOR: Update upgrade document for KIP-1241" This reverts commit 2b4e796d013d3eb2b5ebd712157aae8bb04fbf2a. --- docs/getting-started/upgrade.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/getting-started/upgrade.md b/docs/getting-started/upgrade.md index 6ce3bfae5b9bc..db29a4c2a33b0 100644 --- a/docs/getting-started/upgrade.md +++ b/docs/getting-started/upgrade.md @@ -33,8 +33,8 @@ type: docs ### Notable changes in 4.4.0 * The `ClientQuotaCallback#updateClusterMetadata` method is deprecated and will be removed in Kafka 5.0. Custom implementations of `ClientQuotaCallback` no longer need to override this method, as a default no-op implementation is now provided. For further details, please refer to [KIP-1200](https://cwiki.apache.org/confluence/x/axBJFg). - * The in-memory keystores (used for PEM certificates) now use the default type provided by `KeyStore.getDefaultType()` instead of the hardcoded PKCS12 type. * New configs have been introduced: remote.copy.lag.bytes, remote.copy.lag.ms and their corresponding broker-level configurations. They allow tiered storage redundancy reduced with delayed upload. For further details, please refer to [KIP-1241](https://cwiki.apache.org/confluence/x/A4LMFw). + * The in-memory keystores (used for PEM certificates) now use the default type provided by `KeyStore.getDefaultType()` instead of the hardcoded PKCS12 type. ## Upgrading to 4.3.0 From dccd6165ab0bd8b39c23de04b70491b867c980a1 Mon Sep 17 00:00:00 2001 From: Jian Date: Mon, 25 May 2026 00:03:09 +0800 Subject: [PATCH 5/6] Revert "MINOR:Update upgrade document for KIP-1241" This reverts commit 6327e6f7a1bc5e4b1270bb897846379fe898dd80. --- docs/getting-started/upgrade.md | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/docs/getting-started/upgrade.md b/docs/getting-started/upgrade.md index db29a4c2a33b0..145960a483a67 100644 --- a/docs/getting-started/upgrade.md +++ b/docs/getting-started/upgrade.md @@ -33,8 +33,7 @@ type: docs ### Notable changes in 4.4.0 * The `ClientQuotaCallback#updateClusterMetadata` method is deprecated and will be removed in Kafka 5.0. Custom implementations of `ClientQuotaCallback` no longer need to override this method, as a default no-op implementation is now provided. For further details, please refer to [KIP-1200](https://cwiki.apache.org/confluence/x/axBJFg). - * New configs have been introduced: remote.copy.lag.bytes, remote.copy.lag.ms and their corresponding broker-level configurations. They allow tiered storage redundancy reduced with delayed upload. For further details, please refer to [KIP-1241](https://cwiki.apache.org/confluence/x/A4LMFw). - * The in-memory keystores (used for PEM certificates) now use the default type provided by `KeyStore.getDefaultType()` instead of the hardcoded PKCS12 type. + * The in-memory keystores (used for PEM certificates) now use the default type provided by `KeyStore.getDefaultType()` instead of the hardcoded PKCS12 type. ## Upgrading to 4.3.0 From b5798fd1a4a04de7f6c834e66055a84061843a20 Mon Sep 17 00:00:00 2001 From: Jian Date: Mon, 25 May 2026 00:03:35 +0800 Subject: [PATCH 6/6] MINOR: Update upgrade document for KIP-1241 Signed-off-by: Jian --- docs/getting-started/upgrade.md | 1 + 1 file changed, 1 insertion(+) diff --git a/docs/getting-started/upgrade.md b/docs/getting-started/upgrade.md index 145960a483a67..d3f2eb47751bd 100644 --- a/docs/getting-started/upgrade.md +++ b/docs/getting-started/upgrade.md @@ -34,6 +34,7 @@ type: docs * The `ClientQuotaCallback#updateClusterMetadata` method is deprecated and will be removed in Kafka 5.0. Custom implementations of `ClientQuotaCallback` no longer need to override this method, as a default no-op implementation is now provided. For further details, please refer to [KIP-1200](https://cwiki.apache.org/confluence/x/axBJFg). * The in-memory keystores (used for PEM certificates) now use the default type provided by `KeyStore.getDefaultType()` instead of the hardcoded PKCS12 type. + * New configs have been introduced: remote.copy.lag.bytes, remote.copy.lag.ms and their corresponding broker-level configurations. They allow tiered storage redundancy reduced with delayed upload. For further details, please refer to [KIP-1241](https://cwiki.apache.org/confluence/x/A4LMFw). ## Upgrading to 4.3.0