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

Posted to dev@flume.apache.org by "Johny Rufus (JIRA)" <ji...@apache.org> on 2015/04/17 02:37:13 UTC

[jira] [Updated] (FLUME-2495) Kafka Source may miss events when channel is not available

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

Johny Rufus updated FLUME-2495:
-------------------------------
    Fix Version/s: v1.5.1

> Kafka Source may miss events when channel is not available
> ----------------------------------------------------------
>
>                 Key: FLUME-2495
>                 URL: https://issues.apache.org/jira/browse/FLUME-2495
>             Project: Flume
>          Issue Type: Bug
>          Components: Sinks+Sources
>            Reporter: Gwen Shapira
>            Assignee: Gwen Shapira
>             Fix For: v1.5.1
>
>         Attachments: FLUME-2495.0.patch, FLUME-2495.1.patch, FLUME-2495.2.patch
>
>
> Because the Kafka consumer itself tracks offsets, and we don't restart the consumer when we get channel errors, the consumer will skip messages that we couldn't write to channel, even though we did not advance offset in Zookeeper.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)