java - 从 EventHostProcessor 中的最后一个检查点重新开始消费

Question

给定 EventHostProcessor 的实现，如何强制重播同一处理器内最后一个检查点的事件？

为了明确起见，假设我的分区深度为 100，并且我已经使用了 10 条消息。当我调用此重播方法时，我希望 onEvent 返回我之前使用的 10 条消息中的第一条消息。

在 C# 中，这似乎可以通过使用 Stopwatch 实现，但我没有看到 Java 的等效项。

Answer 1

解决方案似乎是您可以检查点到上次使用的 EventData 的高水位线，也可以检查点到另一个 EventData 实例。

如context.checkpoint(data);

似乎没有办法在 EventProcessorHost 中任意回退到较早的事件。