How to replay all the events for certain service?

[smilingleo]

Let's say orderservice crashed and lost all the data (not in this example, since order and customer share same db here), how can we replay all the events and restore its latest state?

In io.eventuate.local.db.log.common.DbLogBasedCdcProcessor,

  public void start(Consumer<EVENT> eventConsumer) {
    Optional<BinlogFileOffset> startingBinlogFileOffset = offsetStore.getLastBinlogFileOffset();

    process(eventConsumer, startingBinlogFileOffset);
  }

The offsetStore always seeks to the latest offset even though its consumer starts at the earliest.

I guess we can either make it configurable or provide a different implementation of the CdcProcessor.

But the question is, while we replay all the events, the orderservice will emit new events as well, and those events are already published and stored in the event store. So, what do we do? publish them to a separated Topic? What's the recommended operation? Or, is it really practical?