You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Sameer Kumar <sa...@gmail.com> on 2018/03/14 14:42:23 UTC

Changelog topic with retention

Hi,

A changelog would have infinite retention(only one can be specified among
compact or delete), howsover while using windows store, we have
timewindows.until() which specifies the retention.

A KTable can be created using TimeWindows.until(), does that mean that
changelog would have retention as well, even though its time based.

Regards,
-Sameer.

Re: Changelog topic with retention

Posted by Sameer Kumar <sa...@gmail.com>.

Hi All,

Just found the answer to this, a changelog topic can now have both delete
and compact as clean up policy. Also, a retention period can also be set.
So, in case of window store, whatever we specify as until becomes the
retention.ms of the changelog topic.

-Sameer.

On Wed, Mar 14, 2018 at 8:12 PM, Sameer Kumar <sa...@gmail.com>
wrote:

> Hi,
>
> A changelog would have infinite retention(only one can be specified among
> compact or delete), howsover while using windows store, we have
> timewindows.until() which specifies the retention.
>
> A KTable can be created using TimeWindows.until(), does that mean that
> changelog would have retention as well, even though its time based.
>
> Regards,
> -Sameer.
>