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
| Author | Jorge Esteban Quilcate Otoya |
| Status | Discarded |
| JIRA | KAFKA-7718 |
| Wiki | View on Apache Wiki |
| Created | 2020-06-29 |
| Last Modified | 2025-01-04 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.