(kafka) branch trunk updated: MINOR: improve StreamsResetter logging (#18237)

[mjsax]

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

mjsax 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 a9eb06bbdf9 MINOR: improve StreamsResetter logging (#18237)
a9eb06bbdf9 is described below

commit a9eb06bbdf9b3d14736223edc1e3650677e2fe6d
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Wed Dec 18 18:29:42 2024 -0800

    MINOR: improve StreamsResetter logging (#18237)
    
    StreamsResetter should log the deprecation warning only if the deprecated
    flag is used.
    
    Reviewers: Bruno Cadonna <br...@confluent.io>, Chia-Ping Tsai 
<chia7...@gmail.com>
---
 tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java 
b/tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java
index 4a115f5b641..81cd6f9f993 100644
--- a/tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java
+++ b/tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java
@@ -687,7 +687,9 @@ public class StreamsResetter {
         }
 
         public List<String> intermediateTopicsOption() {
-            System.out.println("intermediateTopicsOption is deprecated and 
will be removed in a future release");
+            if (options.has(intermediateTopicsOption)) {
+                System.out.println("WARN: `--intermediate-topics` is 
deprecated and will be removed in a future release");
+            }
             return options.valuesOf(intermediateTopicsOption);
         }