Gwen Shapira created FLUME-2495:
-----------------------------------
Summary: 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
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)
