subject:"Kafka streams internal topic data retention"

Re: Kafka streams internal topic data retention

2017-04-30 Thread Sachin Mittal

topicConfigMap.put("segment.ms", "720"); And using Stores.create().enableLogging(topicConfigMap) you pass this map for creating internal topic (atleast for change log topics this is the way). Sachin On Sun, Apr 30, 2017 at 5:28 PM, Shimi Kiviti wrote: > Hi > > W

Kafka streams internal topic data retention

2017-04-30 Thread Shimi Kiviti

Hi Where can I find what is the Kafka streams internal topic data retention time and how to change it Thanks, Shimi