retention

If you have altered a topic and want to view the topic configuration the following command will be helpful kafka-topics.sh –zookeeper localhost:2181 –describe –topics-with-overrides This will describe only the topics along with configurations that have configurations set that differ from the cluster defaults. If you want to view the configurations for all topic Either you … Read more

log.retention.hours is a property of a broker which is used as a default value when a topic is created. When you change configurations of currently running topic using kafka-topics.sh, you should specify a topic-level property. A topic-level property for log retention time is retention.ms. From Topic-level configuration in Kafka 0.8.1 documentation: Property: retention.ms Default: 7 … Read more