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

io.debezium.transforms.ExtractNewRecordState

    Details

    • Type: Bug
    • Status: Closed (View Workflow)
    • Priority: Trivial
    • Resolution: Explained
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: core-library
    • Labels:
      None
    • Steps to Reproduce:
      Hide

      create a connector using

      curl -X POST -H "Content-Type:application/json" $(hostname):8083/connectors -d '{
      "name": "my_connector_sink",
      "config":

      { "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector", "key.converter": "io.confluent.connect.avro.AvroConverter", "key.converter.schema.registry.url": "myregistry", "key.converter.basic.auth.credentials.source": "USER_INFO", "key.converter.basic.auth.user.info": "user:password", "value.converter": "io.confluent.connect.avro.AvroConverter", "value.converter.schema.registry.url": "myregistry", "value.converter.basic.auth.credentials.source": "USER_INFO", "value.converter.basic.auth.user.info": "user:password", "delete.enabled": "true", "tasks.max": "6", "quote.sql.identifiers": "never", "topics": "mytopic", "table.name.format": "myschema.mytable", "dialect.name": "OracleDatabaseDialect", "connection.url": "myoracletarget", "connection.user": "myoracleschema", "connection.password": "mypwd", "transforms": "TimestampConverter1", "transforms.TimestampConverter1.type": "org.apache.kafka.connect.transforms.TimestampConverter$Value", "transforms.TimestampConverter1.field": "mydate", "transforms.TimestampConverter1.target.type": "Timestamp", "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState", "transforms.unwrap.drop.tombstones": "false", "insert.mode": "upsert", "pk.mode": "record_key", "pk.fields": "c1,c2,c3" }


      }'

      Show
      create a connector using curl -X POST -H "Content-Type:application/json" $(hostname):8083/connectors -d '{ "name": "my_connector_sink", "config": { "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector", "key.converter": "io.confluent.connect.avro.AvroConverter", "key.converter.schema.registry.url": "myregistry", "key.converter.basic.auth.credentials.source": "USER_INFO", "key.converter.basic.auth.user.info": "user:password", "value.converter": "io.confluent.connect.avro.AvroConverter", "value.converter.schema.registry.url": "myregistry", "value.converter.basic.auth.credentials.source": "USER_INFO", "value.converter.basic.auth.user.info": "user:password", "delete.enabled": "true", "tasks.max": "6", "quote.sql.identifiers": "never", "topics": "mytopic", "table.name.format": "myschema.mytable", "dialect.name": "OracleDatabaseDialect", "connection.url": "myoracletarget", "connection.user": "myoracleschema", "connection.password": "mypwd", "transforms": "TimestampConverter1", "transforms.TimestampConverter1.type": "org.apache.kafka.connect.transforms.TimestampConverter$Value", "transforms.TimestampConverter1.field": "mydate", "transforms.TimestampConverter1.target.type": "Timestamp", "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState", "transforms.unwrap.drop.tombstones": "false", "insert.mode": "upsert", "pk.mode": "record_key", "pk.fields": "c1,c2,c3" } }'

      Description

      Hello,
      i have created a kafka-connect docker image from debezium connect-base:1.2.4.Final, and add ojdbc7.jar.
      I want to read messages that comes from dbz pgsql.

      when i set this in the sink connector:

      "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
      "transforms.unwrap.drop.tombstones": "false",

      i face this error,

      {"error_code":400,"message":"Connector configuration is invalid and contains the following 2 error(s):\nInvalid value io.debezium.transforms.ExtractNewRecordState for configuration transforms.unwrap.type: Class io.debezium.transforms.ExtractNewRecordState could not be found.\nInvalid value null for configuration transforms.unwrap.type: Not a Transformation\nYou can also find the above list of errors at the endpoint `/connector-plugins/\{connectorType}

      /config/validate`"}[kafka

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                pierremarie.petit.partner Pierre-Marie Petit
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: