transactions - 如果 kafka spout 被风暴三叉戟重新启动会怎样？

Question

假设 kafka spout 获取了一些消息，然后 spout 任务重新启动。获取的消息会丢失吗？我是 trident 的初学者，我的问题是 trident kafka 事务/不透明喷口。

提前致谢！

Answer 1

我相信只要消息不是ack，它们就不会被提交为消耗，并且 spout 将在启动时重播它们。

另一方面，如果您将 spout 配置为从头开始读取，那么 Kafka-sppout 将从起始偏移点获取它们。