You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Chris Riccomini (JIRA)" <ji...@apache.org> on 2013/10/23 21:21:49 UTC

[jira] [Resolved] (SAMZA-62) KafkaCheckpointManager fails when offset request has error code

     [ https://issues.apache.org/jira/browse/SAMZA-62?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chris Riccomini resolved SAMZA-62.
----------------------------------

    Resolution: Fixed

> KafkaCheckpointManager fails when offset request has error code
> ---------------------------------------------------------------
>
>                 Key: SAMZA-62
>                 URL: https://issues.apache.org/jira/browse/SAMZA-62
>             Project: Samza
>          Issue Type: Bug
>          Components: kafka
>    Affects Versions: 0.6.0
>            Reporter: Chris Riccomini
>            Assignee: Chris Riccomini
>             Fix For: 0.7.0
>
>         Attachments: SAMZA-62.0.patch
>
>
> When the KafkaCheckpointManager makes its offset request to the broker for each checkpoint topic, it doesn't check the offset response's error code. Consequently, the error is swallowed. This makes it very hard to debug when something goes wrong.
> We should just do an ErrorMapping.maybeThrow check on the error code, which will trigger a reconnect when things go wrong.



--
This message was sent by Atlassian JIRA
(v6.1#6144)