-
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 ?