http://kafka.apache.org/documentation.html#topic-config
Check this.
You can use *--alter *
To override/add the default config.
retention.ms can be used to set topic level config.
For internal topics I suppose you need to provide a topic config map before
creating internal topics.
Example:
final Map<String, String> topicConfigMap = new HashMap<String,
String>();
topicConfigMap.put("delete.retention.ms", "7200000");
topicConfigMap.put("min.cleanable.dirty.ratio", "0.01");
topicConfigMap.put("segment.bytes", "104857600");
topicConfigMap.put("segment.ms", "7200000");
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 <shim...@gmail.com> wrote:
> Hi
>
> Where can I find what is the Kafka streams internal topic data retention
> time and how to change it
>
> Thanks,
> Shimi
>
