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.