Re: KTable TTL

2017-02-17 Thread Guozhang Wang
Hello Ara, I'm wondering what this KTable is used for (e.g. join, aggregation, etc)? And is the usage of TTL is because your computational logic can safely ignore key-value pairs that has existed for 24 hours, or is it purely for bounding the state store space usage (for this end, what is your

KTable TTL

2017-02-13 Thread Ara Ebrahimi
Hi, I have a ktable and I want to keep entries in it only for that past 24 hours. How can I do that? I understand rocksdb has support for ttl. Should I set that? How? Should I use kafka-streams window functionality? Would it remove data from old windows? I want to do this because I’m seeing a