Apache Flume自定义接收器不会在EventDeliveryException上重试

问题描述

据我了解，引发EventDeliveryException的目的是将异常标记为暂时的，并在将来重试。

我们有一个自定义接收器类，该数据器将数据索引到Solr（当前未使用Morphlinesolrsink），但是当一个分片死了并再次返回时，除非手动重启Flume，否则Flume根本不会重试索引。

Sink.process中的相关部分是：

@Override
public Status process() throws EventDeliveryException {
//....try indexing data to Solr

} catch (IOException ex) {
    transaction.rollback();
    logger.warn("Solr IO error",ex);
    ex.printstacktrace();
} catch (Throwable ex) {
    transaction.rollback();
    logger.error("process Failed",ex);
    ex.printstacktrace();
    if (ex instanceof Error) {
        throw (Error) ex;
    } else {
        throw new EventDeliveryException(ex);
    }
} finally {
    transaction.close();
}

return status;

在这种情况下如何使Flume重试？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

flume flume-ng