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;