У меня есть этот конкретный сценарий
Avro Source -> Канал памяти -> Sink1, Sink2, Sink 3
Теперь мне нужно внести некоторые изменения в исходное событие, для которого я добавил один перехватчик. Но мне нужно внести определенные изменения в раковину. Как я могу этого добиться?
Как я могу написать несколько перехватчиков, которые относятся к одному источнику, специфичному для приемника. Пример :
Исходное событие из источника = "abc" Interceptor1 преобразует его в "abc1", и эти данные отправляются в приемник1 Interceptor2 преобразует их в "abc2", и эти данные отправляются в приемник2 Interceptor3 преобразует их в "abc3", и эти данные отправляются в приемник3
