Kafka Streams

Debezium captures every insert, update, and delete by reading the database's transaction log and streams them as ordered Kafka events, with no polling and the full before-and-after of each row.

Kafka Streams builds an in-app topology of source, transform, and sink, so reading a topic, uppercasing values with mapValues, and writing to another topic is just stream, mapValues, and to.