Thanks Guozhang! Based on your comment, I searched through the repo and found the associated pull requests and JIRAs.
It looks like most of the support was added in https://issues.apache.org/jira/browse/KAFKA-6521 <https://issues.apache.org/jira/browse/KAFKA-6521> Can you add that to the KIP page for KIP-258? It would make it easier for other people to find when/where the timestamp support was added. Thanks! -James > On May 19, 2022, at 1:24 PM, Guozhang Wang <wangg...@gmail.com> wrote: > > Hi James, > > For kv / time-window stores, they have been geared with timestamps and you > can access via the TimestampedKeyValueStore/TimstampedWindowStore. > > What's not implemented yet are timestamped session stores. > > Guozhang > > On Thu, May 19, 2022 at 12:49 PM James Cheng <wushuja...@gmail.com> wrote: > >> Hi, >> >> I'm trying to see if timestamps are available for records that are stored >> in Kafka Streams state stores. >> >> I saw "KIP-258: Allow to Store Record Timestamps in RocksDB" >> >> https://cwiki.apache.org/confluence/display/KAFKA/KIP-258%3A+Allow+to+Store+Record+Timestamps+in+RocksDB >> < >> https://cwiki.apache.org/confluence/display/KAFKA/KIP-258:+Allow+to+Store+Record+Timestamps+in+RocksDB >>> >> >> But I am not sure if it has been fully implemented. The vote thread went >> through, but it looks like the implementation is still in progress. >> https://issues.apache.org/jira/browse/KAFKA-8382 < >> https://issues.apache.org/jira/browse/KAFKA-8382> >> >> The KIP page says "2.3.0 (partially implemented, inactive)" >> >> Can someone share what the current thoughts are, around this KIP? >> >> Thanks! >> >> -James > > > > -- > -- Guozhang
