[
https://issues.apache.org/jira/browse/KAFKA-13426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13426:
------------------------------------
Description:
KIP-791:
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-791%3A+Add+Record+Metadata+to+State+Store+Context]
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.
was:
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.
> 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
> Priority: Minor
> Labels: kip
>
> KIP-791:
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-791%3A+Add+Record+Metadata+to+State+Store+Context]
> 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)
