conduktor.io ↗

KIP-244 — Add Record Header support to Kafka Streams Processor API

Accepted Kafka 2.0 Streams

Adds Headers access to the Kafka Streams Processor API via ProcessorContext#headers() and exposes headers in ConsumerRecordFactory and OutputVerifier for testing, enabling processors to read, write, and propagate record headers. Headers were available in the producer and consumer APIs but inaccessible in Streams, blocking use cases like distributed tracing context propagation through stream topologies.

Details

AuthorJorge Esteban Quilcate Otoya
StatusAccepted
Kafka Version2.0
JIRAKAFKA-6395
WikiView on Apache Wiki
Created2017-12-21
Last Modified2022-09-29
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.