From: Kai Moritz <kai@juplo.de>
Date: Tue, 15 Jun 2021 18:27:20 +0000 (+0200)
Subject: Automatically rebuild the state after a crash / restart
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=edc88d6eac8c502ab0297380489ccc9ba706b5f0;hp=edc88d6eac8c502ab0297380489ccc9ba706b5f0;p=demos%2Fkafka%2Fdemos-kafka-payment-system-transfer

Automatically rebuild the state after a crash / restart

* Turning of enable.auto.commit and setting auto.offset.reset to earliest
  does the trick in this setup.
* Since no offset-commits are made, all events are re-read on startup.
* The TransferConsumer uses a special instance of TransferService, that
  is initialized with a NoOpMessageService, to replay the restored
  events without generating new events.
---