You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Patrick Stuedi (Jira)" <ji...@apache.org> on 2021/11/01 13:26:00 UTC

[jira] [Created] (KAFKA-13426) Add recordMetadata to StateStoreContext

Patrick Stuedi created KAFKA-13426:
--------------------------------------

             Summary: Add recordMetadata to StateStoreContext
                 Key: KAFKA-13426
                 URL: https://issues.apache.org/jira/browse/KAFKA-13426
             Project: Kafka
          Issue Type: Improvement
          Components: streams
            Reporter: Patrick Stuedi
            Assignee: Patrick Stuedi


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. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)