Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
Prusinowsky opened this issue Jan 22, 2024 · 0 comments

Comments

@Prusinowsky
Copy link

Prusinowsky commented Jan 22, 2024

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
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant