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)