-
Bug
-
Resolution: Not a Bug
-
Major
-
None
-
1.0.0.Beta3
-
None
running docker.io/debezium/connect image.
When I try to register this connector:
{ "name": "paymentscheduler-connector", "config": { "connector.class": "io.debezium.connector.postgresql.PostgresConnector", "tasks.max": "1", "database.hostname": "postgres", "database.port": "5432", "database.user": "postgres", "database.password": "mysecretpassword", "database.dbname" : "postgres", "database.server.name": "paymentschedulerdb", "table.whitelist": "paymentscheduler.payment_scheduler_event", "plugin.name": "wal2json", "key.converter": "org.apache.kafka.connect.json.JsonConverter", "value.converter": "io.debezium.converters.ByteBufferConverter", "key.converter.schemas.enable":"false", "value.converter.schemas.enable": "false", "poll.interval.ms": 300, "transforms" : "outbox", "transforms.outbox.type": "io.debezium.transforms.outbox.EventRouter", "transforms.outbox.table.field.event.payload": "event", "transforms.outbox.table.field.event.payload.id": "payment_schedule_id", "transforms.outbox.table.field.event.type": "event_type", "transforms.outbox.route.by.field": "topic", "transforms.outbox.route.topic.regex": "(?<routedByValue>.*)", "transforms.outbox.route.topic.replacement": "${routedByValue}", "transforms.outbox.table.fields.additional.placement": "event_type:header:eventType,correlation_id:header:b3" } }
This error is returned:
{"error_code":400,"message":"Connector configuration is invalid and contains the following 1 error(s):\nInvalid value io.debezium.converters.ByteBufferConverter for configuration value.converter: Class io.debezium.converters.ByteBufferConverter could not be found.\nYou can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"}
To be able to register the connector, I have added the debezium-core-1.0.0.Beta3.jar on the /kafka/libs.
It's that normal ?