Not sure what you mean by "old state that is not longer needed" ?
key-value entries are kept forever, and there is no TTL. If you want to delete something from the store, you can return `null` as aggregation result though. -Matthias On 4/19/18 2:28 PM, adrien ruffie wrote: > Hi Mihaela, > > > by default a KTable already have a log compacted behavior. > > therefore you don't need to manually clean up. > > > Best regards, > > > Adrien > > ________________________________ > De : Mihaela Stoycheva <mihaela.stoych...@gmail.com> > Envoyé : jeudi 19 avril 2018 13:41:22 > À : users@kafka.apache.org > Objet : Is KTable cleaned up automatically in a Kafka streams application? > > Hello, > > I have a Kafka Streams application that is consuming from two topics and > internally aggregating, transforming and joining data. I am using KTable as > result of aggregation and my question is if KTables are cleaned using some > mechanism of Kafka Streams or is this something that I have to do manually > - clean up old state that is not longer needed? > > Regards, > Mihaela Stoycheva >
signature.asc
Description: OpenPGP digital signature
