[
https://issues.apache.org/jira/browse/KAFKA-17150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-17150:
--------------------------------
Description:
Connect allows users to specify aliases instead of full classes when
configuring plugins. For example, the following configuration is valid:
{noformat}
{
"connector.class": "FileStreamSource",
"topic": "anything",
"key.converter": "JsonConverter"
}{noformat}
In <= 3.7.1 this will pass validation and function correctly.
In 3.8.0-rc1 this will instead fail with this error message:
{noformat}
[2024-07-16 13:58:54,250] ERROR Failed to instantiate key converter class
JsonConverter; this should have been caught by prior validation logic
(org.apache.kafka.connect.runtime.AbstractHerder:462)
java.lang.ClassNotFoundException: JsonConverter
at java.base/java.lang.Class.forName0(Native Method)
at java.base/java.lang.Class.forName(Class.java:534)
at java.base/java.lang.Class.forName(Class.java:513)
at org.apache.kafka.common.utils.Utils.loadClass(Utils.java:426)
at org.apache.kafka.common.utils.Utils.newInstance(Utils.java:415)
at
org.apache.kafka.connect.runtime.AbstractHerder.validateConverterConfig(AbstractHerder.java:460)
at
org.apache.kafka.connect.runtime.AbstractHerder.validateKeyConverterConfig(AbstractHerder.java:528)
at
org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:734)
at
org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$3(AbstractHerder.java:574)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583){noformat}
and this error will eventually be shown to the user:
{noformat}
Connector configuration is invalid and contains the following 1 error(s):
Failed to load class JsonConverter: JsonConverter{noformat}
was:
Connect allows users to specify aliases instead of full classes when
configuring plugins. For example, the following configuration is valid:
{noformat}
{
"connector.class": "FileStreamSource",
"topic": "anything",
"key.converter": "JsonConverter"
}{noformat}
In <= 3.7.1 this will pass validation and function correctly.
In 3.8.0-rc1 this will instead fail with this error message:
{noformat}
[2024-07-16 13:58:54,250] ERROR Failed to instantiate key converter class
JsonConverter; this should have been caught by prior validation logic
(org.apache.kafka.connect.runtime.AbstractHerder:462)
java.lang.ClassNotFoundException: JsonConverter
at java.base/java.lang.Class.forName0(Native Method)
at java.base/java.lang.Class.forName(Class.java:534)
at java.base/java.lang.Class.forName(Class.java:513)
at org.apache.kafka.common.utils.Utils.loadClass(Utils.java:426)
at org.apache.kafka.common.utils.Utils.newInstance(Utils.java:415)
at
org.apache.kafka.connect.runtime.AbstractHerder.validateConverterConfig(AbstractHerder.java:460)
at
org.apache.kafka.connect.runtime.AbstractHerder.validateKeyConverterConfig(AbstractHerder.java:528)
at
org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:734)
at
org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$3(AbstractHerder.java:574)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583){noformat}
> Connect converter validation does not accept class aliases
> ----------------------------------------------------------
>
> Key: KAFKA-17150
> URL: https://issues.apache.org/jira/browse/KAFKA-17150
> Project: Kafka
> Issue Type: Bug
> Components: connect
> Affects Versions: 3.8.0
> Reporter: Greg Harris
> Priority: Blocker
> Fix For: 3.8.0
>
>
> Connect allows users to specify aliases instead of full classes when
> configuring plugins. For example, the following configuration is valid:
> {noformat}
> {
> "connector.class": "FileStreamSource",
> "topic": "anything",
> "key.converter": "JsonConverter"
> }{noformat}
> In <= 3.7.1 this will pass validation and function correctly.
> In 3.8.0-rc1 this will instead fail with this error message:
> {noformat}
> [2024-07-16 13:58:54,250] ERROR Failed to instantiate key converter class
> JsonConverter; this should have been caught by prior validation logic
> (org.apache.kafka.connect.runtime.AbstractHerder:462)
> java.lang.ClassNotFoundException: JsonConverter
> at java.base/java.lang.Class.forName0(Native Method)
> at java.base/java.lang.Class.forName(Class.java:534)
> at java.base/java.lang.Class.forName(Class.java:513)
> at org.apache.kafka.common.utils.Utils.loadClass(Utils.java:426)
> at org.apache.kafka.common.utils.Utils.newInstance(Utils.java:415)
> at
> org.apache.kafka.connect.runtime.AbstractHerder.validateConverterConfig(AbstractHerder.java:460)
> at
> org.apache.kafka.connect.runtime.AbstractHerder.validateKeyConverterConfig(AbstractHerder.java:528)
> at
> org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:734)
> at
> org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$3(AbstractHerder.java:574)
> at
> java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
> at java.base/java.lang.Thread.run(Thread.java:1583){noformat}
> and this error will eventually be shown to the user:
> {noformat}
> Connector configuration is invalid and contains the following 1 error(s):
> Failed to load class JsonConverter: JsonConverter{noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
