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?