A technical deep-dive into how the Kafka Connect JDBC Sink connector handles primary keys for database operations like upserts and deletes.
Troubleshooting a Kafka Connect JDBC Sink error where a TEXT/BLOB column is used as a primary key in MySQL without specifying a key length.
Explains how to use the Flatten Single Message Transform (SMT) in Kafka Connect to convert nested JSON data into a flat structure for database insertion.
Explains how to use Kafka Connect's InsertField Single Message Transform (SMT) to add message timestamps to data sent to a sink.
How to configure the Kafka Connect JDBC Sink connector's pk.fields setting to use a Kafka message's primitive key for UPSERT operations into a PostgreSQL table.
