Kafka Configs Kafka Protocol Wire Format API Versions KIPs Errors Kafka Upgrade Config Advisor Flink SQL
conduktor.io ↗
KIPs / KIP-585

KIP-585 — Filter and Conditional SMTs

Accepted Kafka 2.6 Connect

KIP-585 introduces `Filter` and `Predicate`-based conditional Single Message Transformations (SMTs) in Kafka Connect, allowing records to be dropped or transformed only when a specified predicate matches. Without conditional logic, all SMTs apply unconditionally to every record, requiring connector-specific code to implement routing or selective transformation.

Details

AuthorTom Bentley
StatusAccepted
Kafka Version2.6
JIRAKAFKA-7052
WikiView on Apache Wiki
Created2020-03-24
Last Modified2020-05-20
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.