flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Santoshakhilesh <santosh.akhil...@huawei.com>
Subject Can I write Sink specific interceptor for a single source?
Date Mon, 06 Jun 2016 01:50:35 GMT
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

Regards,
Santosh Akhilesh







Mime
View raw message