在apache风暴中collector.fail是做什么的？

Question

在apache风暴中collector.fail的作用是什么？ 它是从源头（喷口）重播元组，还是仅从它发出的最后一个螺栓重放元组？ 注意：我不固定我的元组，所以在这种情况下会发生什么？

Answer 1

作为文档Guaranteeing Message Processing中的状态，元组将从生成它的喷口重播。

通过指定输入元组作为发出的第一个参数来锚定每个单词元组。由于单词元组被锚定，所以如果单元元组未能在下游处理，则树的根部处的喷口元组将在稍后重播。相反，让我们来看看如果单词tuple是这样发出会发生什么：

_collector.emit（new Values（word））; 以这种方式发出单词元组会导致它未被锚定。如果元组失败被下游处理，则根元组将不会被重播。根据拓扑中需要的容错保证，有时可以发出未锚定的元组。