Flume 代理不会因无法恢复的 solr 错误而停止重试

Flume agent does not stop retrying for unrecoverable solr error

我正在使用 Morphline Solr Sink 在 Solr 中存储信息。我面临的问题是 flume 代理永远不会停止重试失败的请求,有时会随着时间的推移而增加。这会导致使用 M​​axIO Workers 的 flume 警告,并且系统会出现性能问题。除了编写我自己的接收器之外,还有什么方法可以使 flume 停止重试或以指数方式退避以获得更好的系统性能?我的来源是 avroSource。

谢谢。

您应该修复请求失败的原因。

Flume 正在做它设计的事情。它在事务上尝试将这批事件存储在您的商店中。如果它不能存储这些事件,那么,是的,它会继续尝试。

您没有解释导致这些失败的问题。我建议考虑使用拦截器来修复数据中的任何错误或删除您不想存储的事件。