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