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

schofielaj 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 1a176beff1b MINOR: Reword warning message when internal deprecated 
properties are used (#20224)
1a176beff1b is described below

commit 1a176beff1bdff23f9d73edf8aefcbebbf728ca2
Author: Yeikel Santana <em...@yeikel.com>
AuthorDate: Sun Jul 27 16:12:49 2025 -0400

    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 <s7133...@gmail.com>, Andrew Schofield
     <aschofi...@confluent.io>
---
 .../main/java/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);
         }
     }

Reply via email to