SinkProcessor
Sink3
Source
1接收数据
Channel3
Channel1
Sink1
Sink2
Interceptor
7 SinkProcessor有三种:DefaultSinkProcessorLoadBalancingSinkProcessorFailoverSinkProcessor
2处理事件
ChannelSelector
3将事件传递给拦截器链
4 将每个事件传给Channel选择器
5 返回写入事件Channel列表
6 根据Channel选择器的选择结果,将事件写入相应的Channel
Channel2
ChannelProcessor