image.png

ChannelProcessor: Intercaptor拦截器

只留下符合筛选条件的数据，最常见的时间戳拦截器：把log里的时间戳提取出来放在header里（如果一条数据延迟2小时，但是2小时前的文件已关闭，那么会在两小时前文件夹生成一个小文件存储本条数据）

ChannelSelector：channel选择器

ChannelSelector的作用就是选出Event将要被发往哪个Channel。其共有两种类型，分别是Replicating（复制）和Multiplexing（多路复用）。

  • Replicating会将同一个Event发往所有的Channel，

  • Multiplexing会根据相应的原则，将不同的Event发往不同的Channel。

    SinkProcessor：sink处理器

    SinkProcessor共有三种类型，分别是DefaultSinkProcessor、LoadBalancingSinkProcessor和FailoverSinkProcessor

  • DefaultSinkProcessor对应的是单个的Sink、LoadBalancingSinkProcessor和FailoverSinkProcessor对应的是Sink Group，

  • LoadBalancingSinkProcessor可以实现负载均衡的功能，
  • FailoverSinkProcessor可以错误恢复的功能。