Robin Moffatt • 12/22/2020

🎄 Twelve Days of SMT 🎄 - Day 11: Predicate and Filter

This technical article details Apache Kafka 2.6's KIP-585, which introduced predicates for conditional execution of Single Message Transforms (SMTs) and the Filter SMT. It provides a concrete example of using the TopicNameMatches predicate to rename fields from different source topics into a unified schema within a Kafka Connect pipeline, demonstrating a key integration pattern for data harmonization.

0 comments

#Kafka Connect #Data Integration #Apache Kafka