conduktor.io ↗

KIP-66 — Single Message Transforms for Kafka Connect

Accepted Kafka 1.0 Connect

Introduces a Single Message Transforms (SMT) API for Kafka Connect that allows lightweight, stateless, per-record transformations (InsertField, ReplaceField, MaskField, ValueToKey, Cast, TimestampConverter, etc.) to be chained in a connector configuration. Without SMTs, any record transformation required writing a full custom connector or post-processing outside Connect, adding operational complexity.

Details

AuthorNisarg Shah
StatusAccepted
Kafka Version1.0
JIRAKAFKA-3209
WikiView on Apache Wiki
Created2016-07-09
Last Modified2017-06-14
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.