[kafka] branch C0urante-patch-1 created (now b3864a1fa56)

[ce...@apache.org]

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

cegerton pushed a change to branch C0urante-patch-1
in repository https://gitbox.apache.org/repos/asf/kafka.git


      at b3864a1fa56 MINOR: Downgrade log level for conflicting Connect plugin aliases

This branch includes the following new commits:

     new b3864a1fa56 MINOR: Downgrade log level for conflicting Connect plugin aliases

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[kafka] 01/01: MINOR: Downgrade log level for conflicting Connect plugin aliases

[ce...@apache.org]

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

cegerton pushed a commit to branch C0urante-patch-1
in repository https://gitbox.apache.org/repos/asf/kafka.git

commit b3864a1fa56a6747014a596fdc15fad6cfd7a45f
Author: Chris Egerton <ch...@aiven.io>
AuthorDate: Mon Jul 24 09:21:23 2023 -0400

    MINOR: Downgrade log level for conflicting Connect plugin aliases
    
    We've started to see messages like this on startup:
    
    > [2023-07-24 09:16:34,776] WARN Ignoring ambiguous alias 'Value' since it refers to multiple distinct plugins [org.apache.kafka.connect.transforms.HeaderFrom$Value, org.apache.kafka.connect.transforms.ReplaceField$Value, org.apache.kafka.connect.transforms.SetSchemaMetadata$Value, org.apache.kafka.connect.transforms.Cast$Value, org.apache.kafka.connect.runtime.ConnectorConfigTest$AbstractKeyValueTransformation$Value, org.apache.kafka.connect.transforms.ExtractField$Value, org.apache. [...]
    
    This is because `Class::simpleName` doesn't include the names of any outer classes when used on a nested class, and many of the SMTs that we ship out of the box with Kafka Connect use inner classes. For example, the `org.apache.kafka.connect.transforms.ReplaceField` SMT has the inner classes `Key` and `Value`, and the simple name for the `Value` inner class is just `Value` (instead of `ReplaceField$Value` or `ReplaceField.Value`, as one may have expected).
    
    We should downgrade to a lower log level since users may think that something is wrong if they start seeing these messages after an upgrade.
---
 .../java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java
index e88bfa1b03d..88b1fc0484a 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java
@@ -408,7 +408,7 @@ public class PluginUtils {
             if (classNames.size() == 1) {
                 aliases.put(alias, classNames.stream().findAny().get());
             } else {
-                log.warn("Ignoring ambiguous alias '{}' since it refers to multiple distinct plugins {}", alias, classNames);
+                log.debug("Ignoring ambiguous alias '{}' since it refers to multiple distinct plugins {}", alias, classNames);
             }
         }
         return aliases;