关于flume:Flume-Agent内部原理Flink进阶认识

33次阅读

共计 479 个字符,预计需要花费 2 分钟才能阅读完成。

Flume Agent 外部原理

重要组件:

1 ChannelSelector

ChannelSelector 的作用就是选出 Event 将要被发往哪个 Channel。其共有两种类型,别离是 Replicating(复制)和 Multiplexing(多路复用)。
ReplicatingSelector 会将同一个 Event 发往所有的 Channel,Multiplexing 会依据相应的准则,将不同的 Event 发往不同的 Channel。

2 SinkProcessor

SinkProcessor 共有三种类型,别离是 DefaultSinkProcessor、LoadBalancingSinkProcessor 和 FailoverSinkProcessor
DefaultSinkProcessor 对应的是单个的 Sink,LoadBalancingSinkProcessor 和 FailoverSinkProcessor 对应的是 Sink Group,LoadBalancingSinkProcessor 能够实现负载平衡的性能,FailoverSinkProcessor 能够实现故障转移的性能。

正文完
 0