From 1a176beff1bdff23f9d73edf8aefcbebbf728ca2 Mon Sep 17 00:00:00 2001 From: Yeikel Santana Date: Sun, 27 Jul 2025 16:12:49 -0400 Subject: [PATCH] MINOR: Reword warning message when internal deprecated properties are used (#20224) This is a small typo I noticed while working on Connect Original warning message > level=WARN connector_context=The worker has been configured with one or more internal converter properties ([internal.key.converter, schemas.enable, internal.value.converter, schemas.enable]). Support for these properties was deprecated in version 2.0 and removed in version 3.0, and specifying them will have no effect. Instead, an instance of the JsonConverter with schemas.enable set to false will be used. For more information, please visit https://kafka.apache.org/documentation/#upgrade and consult the upgrade notesfor the 3.0 release. class=org.apache.kafka.connect.runtime.WorkerConfig line=310 Reviewers: Ken Huang , Andrew Schofield --- .../org/apache/kafka/connect/runtime/WorkerConfig.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java index 434ab33b99e..b3aded30682 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java @@ -325,12 +325,7 @@ public class WorkerConfig extends AbstractConfig { if (!removedProperties.isEmpty()) { log.warn( "The worker has been configured with one or more internal converter properties ({}). " - + "Support for these properties was deprecated in version 2.0 and removed in version 3.0, " - + "and specifying them will have no effect. " - + "Instead, an instance of the JsonConverter with schemas.enable " - + "set to false will be used. For more information, please visit " - + "https://kafka.apache.org/documentation/#upgrade and consult the upgrade notes" - + "for the 3.0 release.", + + "These properties have been removed since version 3.0 and an instance of the JsonConverter with schemas.enable set to false will be used instead.", removedProperties); } }