From: Kai Moritz <kai@juplo.de>
Date: Sat, 30 Jan 2021 21:39:41 +0000 (+0100)
Subject: The OutboxProducer restores the sequence-number from the wirtten topic
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=a92d318043bf698dc2a949db2b76893c8abf03a1;hp=a92d318043bf698dc2a949db2b76893c8abf03a1;p=demos%2Fkafka%2Foutbox

The OutboxProducer restores the sequence-number from the wirtten topic

* The OutboxProducer consumes the written messages on start-up, extracts the
  send sequence-numbers and recalculates the seen watermarks and the maximal
  sequence-number, for at-least-once semantics.
* This implementation will most probably resend some messages after a crash,
  but it will never skip any unsend messages.
* Messages may be resend despite the recalculated watermarks, because only
  messages with a sequence number lower than the lowest watermark can be
  discarded safely from the outbox, if message-loss is not acceptable.
* Deactivated the integration-test for the loading of the context, because
  it cannot work without an available Kafka-Cluster.
---