Past thread related to TTL:
http://search-hadoop.com/m/Kafka/uyzND1RLg4VOJ84U?subj=Re+Streams+TTLCacheStore
On Thu, Oct 5, 2017 at 9:54 AM, Ted Yu <yuzhih...@gmail.com> wrote:
> Looking at
> streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
> :
>
> throw new UnsupportedOperationException("Change log is
> not supported for store " + this.name + " since it is TTL based.");
> // TODO: support TTL with change log?
> // return TtlDB.open(options, dir.toString(), ttl, false);
>
> On Thu, Oct 5, 2017 at 9:15 AM, Kristopher Kane <kkane.l...@gmail.com>
> wrote:
>
>> Not sure if I have missed it in the streams developer docs, but, is there
>> a
>> mechanism to age data off the state store similar to a key based TTL? It
>> looks like RocksDB has TTL built in so would I pass that via some store
>> configuration?
>>
>>
>> Kris
>>
>
>
