[
https://issues.apache.org/jira/browse/KAFKA-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Li Junjun updated KAFKA-2220:
-----------------------------
Attachment: screenshot.png
> Improvement: Could we support rewind by time ?
> ------------------------------------------------
>
> Key: KAFKA-2220
> URL: https://issues.apache.org/jira/browse/KAFKA-2220
> Project: Kafka
> Issue Type: Improvement
> Affects Versions: 0.8.1.1
> Reporter: Li Junjun
> Attachments: screenshot.png
>
>
> Improvement: Support rewind by time !
> My scenarios as follow:
> A program read record from kafka and process then write to a dir in
> HDFS like /hive/year=xxxx/month=xx/day=xx/hour=10 . If the program goes
> down . I can restart it , so it read from last offset .
> But what if the program was config with wrong params , so I need remove
> dir hour=10 and reconfig my program and I need to find the offset where
> hour=10 start , but now I can't do this.
> And there are many scenarios like this.
> so , can we add a time partition , so we can rewind by time ?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
