A way to chain selectors?

17 views
Skip to first unread message

Serega Sheypak

unread,
Jun 3, 2015, 11:45:55 AM6/3/15
to flume...@googlegroups.com
Hi, is there any easy way to implement such chain

single source getting event
multiplexing selector by event.header named 'XXX'
if header 'XXX'='true' send to channel named 'channelXXXtrue'
by default, do replication and send replicas to two channels 'channelReplica1', 'channelReplica2'

The idea is:
I have a source with custom interceptor. It validates input events. If event is corrupted, it sets event.header named 'XXX'=true
then I need to send corrupted events to special channel. I can do it using selector=multiplexing
Correct events should be replicated and sent to two different channels. Each channel has it's own special Sink (HDFS and Solr).

I don't see any way to set two subsequent selectors and the only way to solve is to introduce intermediate sources. Am I correct?
Reply all
Reply to author
Forward
0 new messages