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
| Author | Jorge Esteban Quilcate Otoya |
| Status | Accepted |
| Kafka Version | 2.0 |
| JIRA | KAFKA-6395 |
| Wiki | View on Apache Wiki |
| Created | 2017-12-21 |
| Last Modified | 2022-09-29 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.