使用baserichbolt时
_collector.fail(tuple)
和
_collector.ack(tuple)
它是否像超时一样导致元组重新出现？或者它只是丢弃元组。如果是的话，失败方法和使用ack有什么区别？
k2fxgqgv1#
ack() 确认一个元组，即告诉storm一个元组已成功处理。 fail() 使一个元组失败，即告诉storm一个元组无法成功处理，因此storm稍后将重新尝试此元组（即，原始源元组将在某个点重新处理）。它基本上是一种快速失败的机制——如果您不在元组的超时时间内确认元组，它也会失败。
ack()
fail()
1条答案
按热度按时间k2fxgqgv1#
ack()确认一个元组，即告诉storm一个元组已成功处理。fail()使一个元组失败，即告诉storm一个元组无法成功处理，因此storm稍后将重新尝试此元组（即，原始源元组将在某个点重新处理）。它基本上是一种快速失败的机制——如果您不在元组的超时时间内确认元组，它也会失败。