06-10-2015 08:33 AM - edited 06-10-2015 09:02 AM
We've got flume Events being published to a KafkaChannel and we're
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.
We are looking for a "parseAsFlumeEvent" flag of some sort but the
source seems to just blindly wrap everything in a new Event. So, we
wonder if we're going about this wrong? Are folks writing interceptors
that unwrap the events? or what?