This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 1ca017a4f6a MINOR: Suppress the deprecation warning for 
`LOG_CLEANER_ENABLE_PROP` in `LogCleanerIntegrationTest` (#21982)
1ca017a4f6a is described below

commit 1ca017a4f6a62f27d786b0e347233faaaf2270a4
Author: Nick Guo <[email protected]>
AuthorDate: Wed Apr 8 01:16:29 2026 +0800

    MINOR: Suppress the deprecation warning for `LOG_CLEANER_ENABLE_PROP` in 
`LogCleanerIntegrationTest` (#21982)
    
    ```
    > Task :storage:compileTestJava
    
/Users/lansg/Project/OpenSource/kafka/kafka/storage/src/test/java/org/apache/kafka/storage/internals/log/LogCleanerIntegrationTest.java:578:
    warning: [removal] LOG_CLEANER_ENABLE_PROP in CleanerConfig has been
    deprecated and marked for removal
            oldConfigMap.put(CleanerConfig.LOG_CLEANER_ENABLE_PROP,
    currentConfig.enableCleaner);
                                          ^
    Note: Some input files use unchecked or unsafe operations.
    Note: Recompile with -Xlint:unchecked for details.
    1 warning
    
    ```
    
    Reviewers: Ken Huang <[email protected]>, Chia-Ping Tsai
     <[email protected]>
---
 .../apache/kafka/storage/internals/log/LogCleanerIntegrationTest.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/storage/src/test/java/org/apache/kafka/storage/internals/log/LogCleanerIntegrationTest.java
 
b/storage/src/test/java/org/apache/kafka/storage/internals/log/LogCleanerIntegrationTest.java
index a8c65daf7ff..02d7a3c7c33 100644
--- 
a/storage/src/test/java/org/apache/kafka/storage/internals/log/LogCleanerIntegrationTest.java
+++ 
b/storage/src/test/java/org/apache/kafka/storage/internals/log/LogCleanerIntegrationTest.java
@@ -541,6 +541,7 @@ public class LogCleanerIntegrationTest {
 
     @ParameterizedTest
     @EnumSource(CompressionType.class)
+    @SuppressWarnings("removal")
     public void cleanerConfigUpdateTest(CompressionType compressionType) 
throws Exception {
         Compression codec = Compression.of(compressionType).build();
         int largeMessageKey = 20;

Reply via email to