我在代码中使用嵌入式flume代理将数据发送到接收器。我使用threadpooltaskexecutor启动一个可运行类，在该类中配置、启动事件并将其放入代理中。
我怎么知道转让成功与否？我需要一个触发器，以防无法以不同的方式处理数据。
似乎没有比配置、启动、放置、停止更多的控制。
例如，我得到：
[sinkrunner pollingrunner loadbalancingskingprocessor]错误org.apache.flume.sinkrunner:160 - 无法传递事件。例外情况随之而来。org.apache.flume.eventdeliveryexception:所有配置的接收器都失败
但我怎么能明白呢？如果停止代理，如何访问发送失败的作业/事件？