Re: KeyValueStore implementation that allows retention policy

2018-04-25 Thread Guozhang Wang
Hello Javier, There are some ticket created for this purpose: https://issues.apache.org/jira/browse/KAFKA-4212 https://issues.apache.org/jira/browse/KAFKA-4273 Please feel free to share your use cases on the ticket, so that we can consider prioritizing this feature in Streams. Guozhang On W

KeyValueStore implementation that allows retention policy

2018-04-25 Thread Javier Holguera
Hi, I have a look around the "state" folder in Kafka Streams and I realised that only WindowStore and SessionStore allows configuring a retention policy. Looking a bit further, it seems that RocksDbSegmentedBytesStore is the main way to implement a store that can clean itself up based on retent