Manu Zhang created GEARPUMP-17:
----------------------------------
Summary: KafkaStorage looks for the wrong offset on replay
Key: GEARPUMP-17
URL: https://issues.apache.org/jira/browse/GEARPUMP-17
Project: Apache Gearpump
Issue Type: Bug
Components: kafka
Reporter: Manu Zhang
Assignee: Manu Zhang
Fix For: 0.8.0
It is wrong for KafkaStorage to look for the offset with largest timestamp
smaller than the "start timestamp" on replay. Instead, it should look for the
smallest timestamp that is equal to or larger than the "start timestamp" since
"start timestamp" means messages before that time have all been processed.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)