我已经做了大量的测试。在这种情况下你会很难受的。当接收器失败时，flume将开始抛出异常。根据流的速度，通道也会被填满，从而导致更多的异常。控制故障的最佳方法是使用故障转移接收器处理器并配置接收器组。这样，如果一个接收器出现故障，您将设置一个备份接收器，并且数据丢失非常少。根据我的经验，我已经设置了一个avro接收器，该接收器连接到拓扑中的第二个flume代理跃点，如果该flume代理发生故障，那么我的故障转移接收器是两个不同的hadoop集群，我通过hdfs接收器将flume事件写入其中一个hadoop集群。然后您必须回填这些事件。我发现netcat源代码对此非常有效。