Robin Moffatt • 2/25/2020

Kafka Connect JDBC Sink - setting the key field name

This technical article explains a specific configuration issue when using the Kafka Connect JDBC Sink connector. It details the error encountered when trying to use a Kafka message's primitive key (like a string) for UPSERT behavior with `pk.mode=record_key` and provides the solution: explicitly setting the `pk.fields` parameter to define the column name in the target database table, using a concrete example with PostgreSQL.

0 comments

#Primary Key #Kafka Connect #Upsert