大数据之Flume:Flume进阶
发布日期:2021-05-07 07:32:05 浏览次数:21 分类:精选文章

本文共 502 字,大约阅读时间需要 1 分钟。

1.Flume事务

在这里插入图片描述
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可以实现故障转移的功能。

上一篇:大数据之Flume:Flume拓扑结构
下一篇:大数据之Flume:实时监控多个文件

发表评论

最新留言

能坚持,总会有不一样的收获!
[***.219.124.196]2025年03月23日 06时41分30秒