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 edd35a693c7 KAFKA-20017 incorrect warn log when alterConfig suceeds 
(#21208)
edd35a693c7 is described below

commit edd35a693c77c53f4d423d18f9648f131649cde7
Author: Lan Ding <[email protected]>
AuthorDate: Wed Dec 24 15:08:35 2025 +0800

    KAFKA-20017 incorrect warn log when alterConfig suceeds (#21208)
    
    Fix incorrect warn log when alterConfig succeeds and add debug logging
    for successful updates.
    
    Reviewers: Luke Chen <[email protected]>, Chia-Ping Tsai
     <[email protected]>
---
 .../java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
 
b/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
index a9d7779673e..4c060b5c1ab 100644
--- 
a/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
+++ 
b/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
@@ -622,8 +622,10 @@ public class MirrorSourceConnector extends SourceConnector 
{
                                 + sourceAndTarget.target() + "' is not 
compatible with " +
                                 "IncrementalAlterConfigs " +
                                 "API", e));
-                    } else {
+                    } else if (e != null) {
                         log.warn("Could not alter configuration of topic {}.", 
k.name(), e);
+                    } else {
+                        log.debug("Successfully altered configuration of topic 
{}.", k.name());
                     }
                 }));
             return null;

Reply via email to