>
Kafka Connect JDBC Sink deep-dive: Working with Primary Keys
The Kafka Connect JDBC Sink can be used to stream data from a Kafka topic to a database such as Oracle, Postgres, MySQL, DB2, etc. It supports many …
Kafka Connect - SQLSyntaxErrorException: BLOB/TEXT column … used in key specification without a key length
I got the error SQLSyntaxErrorException: BLOB/TEXT column 'MESSAGE_KEY' used in key specification without a key length with Kafka Connect …
Kafka Connect JDBC Sink - setting the key field name
I wanted to get some data from a Kafka topic: ksql> PRINT PERSON_STATS FROM BEGINNING; Key format: KAFKA (STRING) Value format: AVRO rowtime: …
Skipping bad records with the Kafka Connect JDBC sink connector
The Kafka Connect framework provides generic error handling and dead-letter queue capabilities which are available for problems with …
Flatten CDC records in KSQL
The problem - nested messages in Kafka Data comes into Kafka in many shapes and sizes. Sometimes it’s from CDC tools, and may be nested like …