我有一个特殊的场景
avro源->内存通道->sink1、sink2、sink 3
现在我需要对我添加了一个拦截器的原始事件做一些更改。但我需要做一些特定的改变。我怎样才能做到这一点？
如何编写多个拦截器，这些拦截器针对单个源，而这些源特定于接收器。例子：
source=“”interceptor1的原始事件将其转换为“1”，此数据发送到sink1 interceptor2将其转换为“2”，此数据发送到sink2 interceptor3将其转换为“3”，此数据发送到sink3