Kinesis Spout 失败（Apache Storm）
Failed Kinesis Spout (Apache Storm)
我已经 运行 对我们的 Apache Storm 拓扑进行了性能测试，并注意到来自 kinesis-spout 的 'Failed' 计数非常高（几乎 1/3 的元组被确认).这个值是多少？
是否是拓扑中在超时值内首尾处理失败的Tuples。有没有办法验证失败计数是由于处理超时造成的？
是的，失败计数显示失败（即未进行端到端处理）的元组数。元组失败可能有两个原因。用户代码（通过调用 Collector.fail(...)）或元组超时导致元组失败。
因此，如果不涉及手动失败，则元组失败的原因是超时。 Storm 中的默认超时为 30 秒，可以通过 Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS.
进行配置
我已经 运行 对我们的 Apache Storm 拓扑进行了性能测试，并注意到来自 kinesis-spout 的 'Failed' 计数非常高（几乎 1/3 的元组被确认).这个值是多少？
是否是拓扑中在超时值内首尾处理失败的Tuples。有没有办法验证失败计数是由于处理超时造成的？
是的，失败计数显示失败（即未进行端到端处理）的元组数。元组失败可能有两个原因。用户代码（通过调用 Collector.fail(...)）或元组超时导致元组失败。
因此，如果不涉及手动失败，则元组失败的原因是超时。 Storm 中的默认超时为 30 秒，可以通过 Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS.