Abbildung 1: Die ersten zwei Segmente der Message 1 werden von einem Segment der Message 2 unterbrochen
Abbildung 2: Der Producer stürzt ab, bevor er alle Segmente einer Message übertragen konnte
Abbildung 3: Der Producer, der übernimmt, weiss nicht, welche Segmente schon übertragen wurden und beginnt daher von vorne. Dadurch werden die ersten Segmente doppelt versendet.
Abbildung 4: Alle Segmente werden solange im Consumer gebuffert, bis die Message, von der als Erstes ein Segment gelesen wurde, komplett ist. Dann wird der Consumer Offset bis zum ältesten im Buffer verbliebenen Segments aufdatiert.
Abbildung 5: Die Daten werden vom Producer in einen externen Speicher geschrieben und vom Consumer von dort gelesen
Hast du auch einen spannenden Use Case? Let's talk!
