java - Storm 是否重放处理超时的元组？

Question

在 Storm 文档中提到， Storm 会重放处理超时的元组。我的问题是 Storm 是否自动执行此操作(不在原始喷口上调用 fail() )或者这是原始喷口重播元组的责任(调用 fail() 并且重播应该在内部甚至外部某个地方实现)?

Answer 1

为了在超时时正确重放，您必须在从 spout 发出时使用 id 锚定元组。当超时发生时，任何你用作 anchor 的东西都会返回到失败方法(fail(object anchorId))。现在您可以使用失败/超时元组的 anchorId 来重播或您想要对超时元组执行的任何其他操作。每个 anchor ID 必须是唯一的。 anchor ID 的一个示例是数据库 ID。当您的元组失败时，您可以使用数据库 ID 重新创建您的元组并重新发出它。所以要回答你的问题，你必须在失败中有你的重播逻辑，你可以使用 anchorId 来重新创建你的元组。希望这些信息对您有所帮助