目录
Flume 拓扑结构
简单串联 (Simple Serial)
复制和多路复用 (Replication and Multiplexing)
负载均衡和故障转移 (Load Balancing and Failover)
聚合 (Aggregation)
示例配置
Flume 拓扑结构
Flume 支持多种拓扑结构来满足不同的数据收集和传输需求。以下是 Flume 中常见的几种拓扑结构：
简单串联 (Simple Serial)
- 描述: 这种模式是将多个 Flume Agent 顺序连接起来，从最初的 Source 开始到最终的 Sink 传送至目的存储系统。
- 特点:
- 适用于简单的数据流管道。
- 不建议桥接过多的 Flume Agent，因为数量过多可能会影响传输速率。
- 一旦传输过程中某个节点 Flume Agent 宕机，可能会影响整个传输系统。
复制和多路复用 (Replication and Multiplexing)
- 描述: Flume 支持将事件流向一个或多个目的地。这种模式可以将相同数据复制到多个 Channel 中，或者将不同数据分发到不同的 Channel 中，Sink 可以选择传送到不同的目的地。
- 特点:
- 复制: 将同一个事件复制并发送到多个 Channel 或 Sink。
- 多路复用: 根据预定义的规则，将不同的事件发送到不同的 Channel 或 Sink。
- 这种结构增加了数据的灵活性和可扩展性。
负载均衡和故障转移 (Load Balancing and Failover)
- 描述: Flume 支持使用将多个 Sink 逻辑上分到一个 Sink 组，Sink 组配合不同的 SinkProcessor 可以实现负载均衡和错误恢复的功能。
- 特点:
- 负载均衡: 在多个 Sink 之间分配负载，提高系统的吞吐量。
- 故障转移: 当主 Sink 失败时，自动切换到备选 Sink。
聚合 (Aggregation)
- 描述: 这种模式是我们最常见的，也非常实用，尤其是在日常 Web 应用中。Web 应用通常分布在上百个服务器，甚至上千个、上万个服务器。产生的日志，处理起来非常麻烦。使用 Flume 的这种组合方式能很好地解决这一问题。
- 特点:
- 每台服务器部署一个 Flume Agent 采集日志。
- 将这些日志传送到一个集中收集日志的 Flume Agent。
- 由该集中 Flume Agent 上传到 HDFS、Hive、HBase 等存储系统进行日志分析。
- 适用于需要从多个数据源收集数据的情况。
- 提高了数据收集的效率和可靠性。
示例配置
这里提供一个简单的串联拓扑结构的配置示例：
# 定义一个名为 a1 的 Agent
a1.sources = <Source1> <Source2>
a1.channels = <Sink1> <Sink2>
a1.sinks = <Channel1> <Channel2>
# 将 Source、Channel 和 Sink 配置到一起
a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100
a1.sinks.k1.type = logger
# 连接 Source、Channel 和 Sink
a1.sources.r1.channels = <Channel1>
a1.sinks.k1.channel = <Channel2>在这个例子中，我们定义了一个 Agent (a1)，它有一个 Source (r1)、一个 Channel (c1) 和一个 Sink (k1)。Source (r1) 用来接收网络数据，Channel (c1) 用作中间存储，而 Sink (k1) 用于日志输出。
