Page History

...

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 ProcessContext (::recordMetadata()), and it is present in the abstract class that implements both ProcessorContext and StateStoreContext, but the method is not currently exposed through the StateStoreContext interface that is used by , so it is not available in the state stores. 

The task of this ticket is to expose recordMetadata via the StateStoreContext. 

...