Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-3508

ReadToInsertEvent SMT needs to set ConfigDef

    XMLWordPrintable

Details

    Description

      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)
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            johnjmartin John Martin (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: