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
| Author | Patrick Stuedi |
| Status | Accepted |
| Kafka Version | 3.2 |
| JIRA | KAFKA-13426 |
| Wiki | View on Apache Wiki |
| Created | 2021-11-01 |
| Last Modified | 2021-11-16 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.