You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flume.apache.org by Tim Williams <wi...@gmail.com> on 2015/06/10 15:36:29 UTC

Events from KafkaChannel in KafkaSource

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 ?

Thanks,
--tim

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