flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Williams <william...@gmail.com>
Subject Events from KafkaChannel in KafkaSource
Date Wed, 10 Jun 2015 13:36:29 GMT
Hi All,
I've got flume events being published to a KafkaChannel and I'm
wanting to pick those up in a KafkaSource for further processing.  It
seems that the events coming across the channel get wrapped in another
event inside the KafkaSource though.

I was looking for a "parseAsFlumeEvent" flag of some sort but the
source[1] seems to just blindly wrap everything in a new Event. So, I
wonder if I'm going about it wrong?  Are folks writing interceptors
that unwrap the events?  or ?


[1] - https://github.com/apache/flume/blob/trunk/flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java

View raw message