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 <[email protected]>
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 [email protected] or file a JIRA ticket
with INFRA.
---
