用新拓扑交换现有拓扑

Question

我在我的 Storm 拓扑中添加了新的螺栓，想用新的拓扑交换现有的拓扑 one.How 我能否以这样的方式实现它，即当第二个拓扑启动时它不会读取相同的消息再次.

Answer 1

如果您使用 Storm 提供的 Kafka Spout 从 Kafka 读取数据，它会将其偏移量存储在 Zookeeper 中。如果保持 SpoutConfig 中定义的 id 相同，则每次 Kafka Spout 重新启动时，它都应该检查 Zookeeper 并从上次提交的偏移量重新启动。实现不再阅读相同消息的目标。