conduktor.io ↗

KIP-791 — Add Record Metadata to StateStoreContext

Accepted Kafka 3.2 Streams

Adds `recordMetadata()` to the `StateStoreContext` public interface so state stores can access the source record's offset and partition metadata during processing. `AbstractProcessorContext` already implements this method internally, but it is not exposed through the `StateStoreContext` interface, preventing stores from implementing Read-Your-Writes consistency or offset tracking.

Details

AuthorPatrick Stuedi
StatusAccepted
Kafka Version3.2
JIRAKAFKA-13426
WikiView on Apache Wiki
Created2021-11-01
Last Modified2021-11-16
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.