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
