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
>
