gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Manu Zhang (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (GEARPUMP-17) KafkaStorage looks for the wrong offset on replay
Date Wed, 06 Apr 2016 12:12:25 GMT

    [ https://issues.apache.org/jira/browse/GEARPUMP-17?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15228164#comment-15228164
] 

Manu Zhang commented on GEARPUMP-17:
------------------------------------

PR link:
[https://github.com/gearpump/gearpump/pull/2030]

> 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)

Mime
View raw message