java - 如何阻止 Apache Storm 消息在拓扑中间重播？

Question

所以我们有一个线性拓扑。假设 Bolt 2 进行了一些 jaxb 解析，但由于某种原因它无法解析 xml。我们不希望它转到 bolt 3 或 4。我们只想停止该过程。

我们如何停止该过程？

Answer 1

只需确认传入的元组而不发出任何内容。

public void execute(Tuple tuple) {
    try {
        // process tuple here
        collector.emit("your_stream",tuple,new Values(value));
    } catch(Execption e) {
        // don't emit
    } finally {
        collector.ack(tuple);
    }
}