java - Storm Bolt 确认元组，但 Spout 以很大的延迟使它们失败

问题描述

我有一个非常简单的拓扑结构。Spout -> Bolt 就是这样。但是每次我得到这张照片的时间：Storm UI。并且不知道为什么它会发生。Bolt 处理所有元组，但 spout 失败。每个 bolt 有 3 个执行器，每个 spout 有 3 个执行器，以及 3 个 Kafka 分区。我已经像这里的答案一样添加了这个配置（Storm Bolts acking but spout is failed），但它没有帮助，与那个例子不同，我没有在我的结构中没有被某个螺栓确认的元组：

TOPOLOGY_MAX_SPOUT_PENDING = 1000

也许还有一些其他重要的 spout 配置可以帮助解决它或需要注意的指标？Storm 的版本是 2.3.0。

标签： javaapache-stormapache-storm-configs

java - Storm Bolt 确认元组，但 Spout 以很大的延迟使它们失败

问题描述

解决方案

推荐阅读