jweinste created FLUME-2861:
-------------------------------
Summary: KafkaChannel decomission
Key: FLUME-2861
URL: https://issues.apache.org/jira/browse/FLUME-2861
Project: Flume
Issue Type: Bug
Components: Channel
Affects Versions: v1.6.0
Reporter: jweinste
Events may be taken, but not Transaction.committed when decommission is called,
resulting in potential loss of data.
doTake()...
eventTaken = true;
events.get().add(e);
stop()...
private void decommissionConsumerAndIterator(ConsumerAndIterator c) {
if (c.failedEvents.isEmpty()) {
c.consumer.commitOffsets();
}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
