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 <[email protected]>
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 <[email protected]>, Andrew Schofield
<[email protected]>
---
.../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);
}
}