You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Li Junjun (JIRA)" <ji...@apache.org> on 2015/05/27 05:19:17 UTC
[jira] [Updated] (KAFKA-2220) Improvement: Could we support rewind
by time ?
[ 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)