Re: Are timestamps available for records stored in Kafka Streams state stores?

2022-05-20 Thread Matthias J. Sax
Added. Feel free to update wiki pages with smaller details like this directly. -Matthias On 5/19/22 2:27 PM, James Cheng wrote: 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

Re: Are timestamps available for records stored in Kafka Streams state stores?

2022-05-19 Thread James Cheng
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 Can you add that to the KIP

Re: Are timestamps available for records stored in Kafka Streams state stores?

2022-05-19 Thread Guozhang Wang
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 wrote: > Hi, > > I'm trying

Are timestamps available for records stored in Kafka Streams state stores?

2022-05-19 Thread James Cheng
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