如果 kafka spout 被 storm trident 重启会怎样？

Question

假设 kafka spout 获取了一些消息，此时 spout 任务重新启动。抓取的消息会丢失吗？我是 trident 的初学者，我的问题是关于 trident kafka transactional/opaque spout。

提前致谢！

Answer 1

我相信只要消息不是 ack，它们就不会在消费时提交，spout 将在启动时重放它们。

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