-
Bug
-
Resolution: Done
-
Minor
-
1.5.0.Final, 1.6.0.Alpha1
-
None
-
False
-
False
-
Undefined
-
-
Related to: https://issues.redhat.com/browse/DBZ-2788
Creating a connector with:
"transforms.readToInsert.type": "io.debezium.connector.mysql.transforms.ReadToInsertEvent", "transforms": "readToInsert,..."
Fails with:
org.apache.kafka.connect.errors.ConnectException: io.debezium.connector.mysql.transforms.ReadToInsertEvent.config() must return a ConfigDef that is not null. at org.apache.kafka.connect.runtime.ConnectorConfig$EnrichablePlugin.getConfigDefFromConfigProvidingClass(ConnectorConfig.java:512) at org.apache.kafka.connect.runtime.ConnectorConfig$EnrichablePlugin.configDefsForClass(ConnectorConfig.java:472) at org.apache.kafka.connect.runtime.ConnectorConfig$2.configDefsForClass(ConnectorConfig.java:331) at org.apache.kafka.connect.runtime.ConnectorConfig$EnrichablePlugin.populateConfigDef(ConnectorConfig.java:453) at org.apache.kafka.connect.runtime.ConnectorConfig$EnrichablePlugin.enrich(ConnectorConfig.java:437) at org.apache.kafka.connect.runtime.ConnectorConfig.enrich(ConnectorConfig.java:360) at org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:355) at org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$1(AbstractHerder.java:326) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829)