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:06:17 UTC

[jira] [Created] (KAFKA-2220) Improvement: Could we support rewind by time ?

Li Junjun created KAFKA-2220:
--------------------------------

             Summary: 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


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)