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

Hari Shreedharan commented on FLUME-2298:
-----------------------------------------

I also wrote one a few weeks ago, which uses Kafka: 
https://github.com/harishreedharan/flume/blob/kafka-channel/flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java

> Replication Channel
> -------------------
>
>                 Key: FLUME-2298
>                 URL: https://issues.apache.org/jira/browse/FLUME-2298
>             Project: Flume
>          Issue Type: New Feature
>          Components: Channel
>            Reporter: Ted Malaska
>            Assignee: Ted Malaska
>         Attachments: Flume Replication Channel Design.0.3.pdf, 
> FlumeDistributedChannelDesign.0.1.pdf, 
> FlumeDistributedChannelDesign.0.2.1.pdf, FlumeDistributedChannelDesign.0.2.pdf
>
>
> This channel will allow for events to be persisted with a plugable method on 
> more then one agent or node.  
> The goal is to gain the following benefits:
> 1. Events will continue to flow to sinks with out loss or with out large 
> delay even in the case of node failure.
> 2. Protect against loss in the case of a complete single node failure



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

Reply via email to