apache-storm - Kafka Storm spout 改变拓扑并从旧偏移量中消费

Question

我正在使用 kafka spout 来消费消息。但是，如果我必须更改拓扑并上传，那么它会从旧消息恢复还是从新消息开始？ Kafka spout 让我们可以指定从哪里消费的时间戳，但我怎么知道时间戳？

Answer 1

spoutConfig.forceStartOffsetTime(-1);

It will choose the latest offset written around that timestamp to start consuming. You can force the spout to always start from the latest offset by passing in -1, and you can force it to start from the earliest offset by passing in -2.

references