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

io.debezium.transforms.ExtractNewRecordState

    XMLWordPrintable

Details

    • Bug
    • Resolution: Not a Bug
    • Trivial
    • None
    • None
    • core-library
    • None
    • False
    • False
    • Undefined
    • 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

      Attachments

        Activity

          People

            Unassigned Unassigned
            pmpetit Pierre-Marie Petit (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: