GitHub user bill-warshaw opened a pull request: https://github.com/apache/kafka/pull/1972
KAFKA-3224: New log deletion policy based on timestamp * adds a new topic-level broker configuration, `log.retention.min.timestamp` * if unset, this setting is ignored * setting this value to a Unix timestamp will allow the log cleaner to delete any segments for a given topic whose last timestamp is earlier than the set timestamp -- ### [KIP-47](https://cwiki.apache.org/confluence/display/KAFKA/KIP-47+-+Add+timestamp-based+log+deletion+policy) ### [JIRA](https://issues.apache.org/jira/browse/KAFKA-3224) You can merge this pull request into a Git repository by running: $ git pull https://github.com/bill-warshaw/kafka KAFKA-3224 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1972.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1972 ---- commit 008dc813d82e5938201f069712ba1bd44277e755 Author: Bill Warshaw <bill.wars...@appian.com> Date: 2016-02-02T16:45:47Z KAFKA-3224: New log deletion policy based on timestamp * setting log.retention.min.timestamp will set a timestamp for a log, and any message before that timestamp is eligible for deletion ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---