A tiny, batteries-included setup that streams five Postgres tables via Debezium Postgres Source into Kafka, then lands them in Postgres (analytics) via Confluent JDBC Sink with UPSERTs + hard deletes.

This is a very simple Kafka Connect SMT which takes the entire key or value record and transforms it to a new record which contains exactly one field with a JSON representation of the origin record.