The OutboxProducer restores the sequence-number from the wirtten topic
authorKai Moritz <kai@juplo.de>
Sat, 30 Jan 2021 21:39:41 +0000 (22:39 +0100)
committerKai Moritz <kai@juplo.de>
Sun, 16 May 2021 21:53:16 +0000 (23:53 +0200)
* 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.


No differences found