请说明在 Apache Flume 中，如何配置多个 Sink 以实现负载均衡（Load Balancing）？

回答思路

1. 【回答框架 1】Flume 通过 Sink 组（Sink Group）和 Sink Processor 实现多 Sink 负载均衡。Sink 组将多个 Sink 聚合，Processor 负责选择 Sink 发送事件。默认 Processor 是 DefaultSinkProcessor（单 Sink），需配置为 LoadBalancingSinkProcessor。
2. 【回答框架 2】配置步骤：在 Channel 上定义 Sink 组，将多个 Sink 加入同一组，并指定 processor.type 为 load_balance。示例如下：sinkgroups = g1，sinkgroups.g1.sinks = s1 s2，sinkgroups.g1.processor.type = load_balance。
3. 【回答框架 3】负载均衡策略通过 processor.selector 配置，支持 round_robin（轮询）和 random（随机）两种。轮询平均分配事件，随机则随机选择 Sink。可配置 selector 相关参数，如 backoff（故障回退）设置，当 Sink 故障时暂时避免向该 Sink 发送。
4. 【回答框架 4】LoadBalancingSinkProcessor 会维护 Sink 状态，当某 Sink 写失败时，根据 backoff 配置将其标记为不可用，并在失败次数超过阈值后暂停一段时间，减少无效尝试。这种机制提高了整体写入的可用性和吞吐量。
5. 【回答框架 5】注意：负载均衡不保证事务语义，事件可能被重发或乱序。配置时需确保 Sink 之间独立，且 Channel 的容量和事务容量要适配，避免因单个 Sink 阻塞影响整个管道。
6. 【关键点 1】使用 Sink 组聚合多个 Sink，配置 processor.type 为 load_balance。
7. 【关键点 2】支持 round_robin 和 random 两种选择策略。
8. 【关键点 3】可配置 backoff 与 backoff 阈值，实现故障期间的自动规避。
9. 【关键点 4】负载均衡主要提升吞吐和可用性，不解决业务层幂等与顺序问题。
10. 【易错点 1】负载均衡不保证消息顺序和事务一次性，需在业务层处理重复或乱序。
11. 【易错点 2】若个别 Sink 持久化能力不足，可能造成数据倾斜，需结合监控调整权重。
12. 【易错点 3】错误配置 selector 参数（如拼写错误）会导致 processor 回退到默认，无负载均衡效果。