Status
Current state: Under discussion
Discussion thread: here
JIRA: here [Change the link from KAFKA-1 to your own ticket]
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
Motivation
In order for state stores to provide stronger consistency in the future (e.g., RYW consistency) they need to be able to collect record metadata (e.g., offset information).
Today, we already make record metadata available in the AbstractProcessContext (recordMetadata()), but the call is not currently exposed through the StateStoreContext interface that is used by the state store.
The task of this ticket is to expose recordMetadata in the StateStoreContext.
Public Interfaces
The following interface will change:
- org.apache.kafka.stream.processor.StateStoreInterface - adding method recordMetadata()
Proposed Changes
The code segment below shows the actual code change together with the corresponding JavaDoc:
Compatibility, Deprecation, and Migration Plan
Rejected Alternatives
None.