flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hari Shreedharan <hshreedha...@cloudera.com>
Subject Re: Flume && Kafka Integration
Date Tue, 17 Mar 2015 21:31:41 GMT
I have seen one other report recently with the optional mapping issues. Can you also send your
configuration? I’d like to investigate this and figure out what the issue is.

Hari Shreedharan

> On Mar 17, 2015, at 2:24 PM, Mangtani, Kushal <Kushal.Mangtani@viasat.com> wrote:
> Hello,
> We are using Flume in our prod env to ingest data. A while back, we decided to extend
the functionality and added kafka for real time monitoring.
> So, the Flume Source forks off and deposits the data into two separate channels ,one
if HDFS(required mapping) and other is Kafka(optional mapping). We have made the KafkaChannels
as optional selector mapping <http://flume.apache.org/releases/content/1.4.0/FlumeUserGuide.html#fan-out-flow>
so that any issue with Kafka should not block the HDFS pipeline.
> However, I have noticed this never happens. Any issue with Kafka cluster eventually also
brings down the HDFS ingestion. So, my question is that either Optional Channel Mapping in
flume src code does not works correctly OR kafka-sink/kafka cluster  I am using is outdated
? Any inputs will be appreciated.
> Env:
> Ubuntu 12.04 
> CDH 5 flume 1.4
> Kafka Src Download - 2.9.1-
> Using Custom Flume-Kafka Sink https://github.com/baniuyao/flume-ng-kafka-sink <https://github.com/baniuyao/flume-ng-kafka-sink>
> - Kushal 

View raw message