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

如何解决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重试？