KIP-145 — Expose Record Headers in Kafka Connect

Accepted Kafka 1.1 Connect

Exposes Kafka record headers to Kafka Connect by adding a Headers abstraction to ConnectRecord with typed values (via Schema) and a HeaderConverter SPI for serialization/deserialization. KIP-82 introduced headers at the broker/client level, but the Connect framework had no mechanism to propagate or transform header data in connectors and SMTs.

Details