conduktor.io ↗

KIP-634 — Complementary support for headers and record metadata in Kafka Streams DSL

Discarded Streams

Extends the Kafka Streams DSL with `mapValueToRecord` and `setRecordHeaders` operators that expose record metadata (topic, partition, offset, timestamp, headers) inside stateless and stateful DSL transformations. Currently such access requires dropping down to the low-level Processor API and re-implementing DSL operations like joins from scratch.

Details

AuthorJorge Esteban Quilcate Otoya
StatusDiscarded
JIRAKAFKA-7718
WikiView on Apache Wiki
Created2020-06-29
Last Modified2025-01-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.