首页 > Web开发 > 详细

Flume Agent内部原理-Flink进阶认识

时间:2021-04-08 01:15:27      阅读:26      评论:0      收藏:0      [点我收藏+]

转:

Flume Agent内部原理-Flink进阶认识

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可以实现故障转移的功能。

转:

Flume Agent内部原理-Flink进阶认识

Flume Agent内部原理-Flink进阶认识

原文:https://www.cnblogs.com/wangtcc/p/14630073.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!