I think what you need is "multiplexing", you can read about it in the user guide
Hi All ,
I have this particular scenario
Avro Source -> Memory Channel - > Sink1 , Sink2 , Sink 3
Now I need to do some changes to original even for which I added one interceptor. But I need to make sink specific changes. How can I achieve this ?
How can I write multiple interceptors which to single source which are specific to sink.
If this is not possible can following configuration work which is similar to multi agent config
Avro Source 1 -> Interceptor1 -> Avro Sink 1 ----- Avro Source 2 -> Interceptor 2 - > Sink 1
----- Avro Source 3 -> Interceptor 3 - > Sink 2