confluentinc/kafka-connect-jdbc

Debezium Postgres connector error: io.debezium.connector.postgresql.converters.PostgresCloudEventsProvider not a subtype

Prusinowsky opened this issue · 1 comments

I'm encountering an issue while starting my Debezium PostgreSQL connector in version 2.5.0.Final. on version Kafka Connect 3.6.1.

ERROR Stopping due to error (org.apache.kafka.connect.cli.AbstractConnectCli:100)
java.util.ServiceConfigurationError: io.debezium.converters.spi.CloudEventsProvider: io.debezium.connector.postgresql.converters.PostgresCloudEventsProvider not a subtype

On version kafka connect 3.5.0. everything works correctly.

I let myself copy post from stackoverflow, because I have the same issue as Weslay mentioned there.
https://stackoverflow.com/questions/77815820/debezium-postgres-connector-error-io-debezium-connector-postgresql-converters-p

Zookeeper is running smoothly, as well as Kafka. Here's how my connect-standalone and `dbz-connector´ are configured:|
connect-standalone.properties

bootstrap.servers=localhost:9092

key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true
value.converter.schemas.enable=true

offset.storage.file.filename=/tmp/connect.offsets

plugin.path=/usr/share/java,/home/user/kafka_2.13-3.6.1/connectors,

dbz-test-connector.propertiers

name=dbz-test-connector
connector.class=io.debezium.connector.postgresql.PostgresConnector
tasks.max=1
database.hostname=localhost
database.port=5432
database.user=postgres
database.password=postgres
database.dbname =test
database.server.name=DBTestServer
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=false
value.converter.schemas.enable=false

However, when attempting to start the connector with the following command:

bin/connect-standalone.sh config/connect-standalone.properties config/dbz-test-connector.properties

It fails with the error:

ERROR Stopping due to error (org.apache.kafka.connect.cli.AbstractConnectCli:100) java.util.ServiceConfigurationError: io.debezium.converters.spi.CloudEventsProvider: io.debezium.connector.postgresql.converters.PostgresCloudEventsProvider not a subtype
1123 commented

Hi Patryk,

this answer is probably too late, but the question you are asking should better be posted on the debezium github repository. This repository only contains the JDBC source and sink connectors.

Kind regards