We are currently running a POC to prove we can replicate MS SQL Server tables from one server to another. We currently have CDC configured on the source table and have a Debezium connector configured. This data flows into a topic with no issues. Now using a JDBC sink connector, we want to read from …

Well, it is up to you when to apply the unwrapping, but enveloping of the data was implemented there for a reason actually, so I would recommend using it on the Sink connector side. As of fields.blacklist - sorry for the confusion, what I meant was actually ReplaceField SMT , which allows you to whi…

SQL Debezium source to topic to JDBC sink target

Kafka Connect Managed Connectors

pebriggs 11 February 2022 22:27 5

That ReplaceField did the trick!
Also had issues with the DateTime and found a setting for that too.
Thanks a bunch!

1 Like

Connector Debezium SQL - Failed

Topic		Replies	Views
Creating new column in sink database using primary_key from source database (debezium - jdbc) connectors Kafka Connect	1	735	26 April 2024
SMT debezium to replace a string with another in topic name Self-Managed Connectors	2	2823	17 January 2023
Cannot get JDBC sink to work from MS SQL source Kafka Streams	1	3141	19 November 2021
Inserting data in multiple tables from single topic using JDBC Sink Connector Kafka Connect	4	1646	28 February 2024
How Sink Connector reflect DDL Kafka Connect	5	3584	1 August 2022

SQL Debezium source to topic to JDBC sink target

Related topics