MINOR: Optimize log printing format for AbstractHerder#validateConver…

…terConfig (#18199) Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
apache · Dec 30, 2024 · af7f403 · af7f403
1 parent 4080f19
commit af7f403
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java
@@ -469,7 +469,7 @@ private <T> ConfigInfos validateConverterConfig(
             VersionRange range = PluginUtils.connectorVersionRequirement(pluginVersion);
             pluginInstance = (T) plugins().newPlugin(pluginClass, range, connectorLoader);
         } catch (VersionedPluginLoadingException e) {
-            log.error("Failed to load {} class {} with version {}: {}", pluginName, pluginClass, pluginVersion, e);
+            log.error("Failed to load {} class {} with version {}", pluginName, pluginClass, pluginVersion, e);
             pluginConfigValue.addErrorMessage(e.getMessage());
             pluginVersionValue.addErrorMessage(e.getMessage());
             return null;
@@ -479,7 +479,7 @@ private <T> ConfigInfos validateConverterConfig(
             return null;
         } catch (InvalidVersionSpecificationException e) {
             // this should have been caught by prior validation logic
-            log.error("Invalid version range for {} class {}: {}", pluginName, pluginClass, pluginVersion, e);
+            log.error("Invalid version range for {} class {} with version {}", pluginName, pluginClass, pluginVersion, e);
             pluginVersionValue.addErrorMessage(e.getMessage());
             return null;
         }