有什么方法可以在Storm bolts的一部分中访问元组吗

Question

// TimingBolt
@Override
public void execute(Tuple input) {
    if (TupleUtils.isTick(input)) {
        collector.emit(streamA, input, new Values("Tick"));
    } else {
        collector.emit(streamB, new Values("Message"));
    }
}

// The AggregateBolt after TimingBolt
@Override
public void execute(Tuple input) {
    if (input.getString(0).equals("Tick")) {
        collector.emit(new Values("Get Tick"));
        collector.ack();
    } else {
        // do something else
        collector.emit(new Values("Not Tick"));
    }
}

我希望除了TimingBolt和AggregateBolt之外的螺栓可能超出ACK树的范围。

文档http://storm.apache.org/documentation/probureing-message-processing.html没有显示任何关于此问题的内容。这是一个有效的场景，还是从喷口启动ack是使ack工作的唯一方法？

Answer 1

你得从壶嘴开始。

明确地说，您不能保证使用所谓的“可靠拓扑”传递消息。相反，您可以保证一个元组和它的所有“子代元组”都被完全交付和处理，或者将通知喷口失败。失败的消息可以自动重新发出，但最终会有一个不再重试元组的小窗口。为了使其发挥作用，spout具有一些bolt所不具备的可靠的元组行为：（1）使用元组发出对象id的能力和（2）当元组最终成功或失败时使用该id调用的方法（分别为ack(id)和fail(id)）。由于bolt没有这些行为，因此不能从bolt启动可靠的元组处理。

考虑使用topology_tick_tuple_freq_secs直接配置第二个螺栓。