Debezium Server connector config failing

[Blake Wolf]

I am running Debezium Server 1.7.2 final from https://repo1.maven.org/maven2/io/debezium/debezium-server-dist/1.7.2.Final/debezium-server-dist-1.7.2.Final.tar.gz

I am configuring a producer that reads from SqlServer and pushes to Kafka.

Has anyone run into the following error:

org.apache.kafka.common.KafkaException: cla ss org.apache.kafka.connect.json.JsonConverter is not an instance of org.apache.kafka.common.serialization.Serializer

My application.properties

debezium.sink.type=kafka
debezium.sink.kafka.producer.bootstrap.servers=xxx.us-east-1.amazonaws.com:9092
debezium.sink.kafka.producer.key.converter.schemas.enable=true
debezium.sink.kafka.producer.value.converter.schemas.enable=true
debezium.sink.kafka.producer.key.serializer=org.apache.kafka.connect.json.JsonConverter
debezium.sink.kafka.producer.value.serializer=org.apache.kafka.connect.json.JsonConverter
debezium.source.connector.class=io.debezium.connector.sqlserver.SqlServerConnector
debezium.source.tasks.max=1
debezium.source.database.hostname=sqlServerHost
debezium.source.database.port=1433
debezium.source.database.user=user
debezium.source.database.password=****************
debezium.source.database.dbname=databasename
debezium.source.database.server.name=.
debezium.source.database.encrypt=false
debezium.source.database.history.producer.security.protocol=PLAINTEXT
debezium.source.database.history.kafka.bootstrap.servers=xxx.us-east-1.amazonaws.com:9092
debezium.source.database.history.kafka.topic=schema-changes
debezium.source.table.include.list=dbo.Employee

[jiri.p...@gmail.com]

Hi,

for serializers you should use serializers not converters.

See org.apache.kafka.connect.json.JsonSerializer

J.