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)
