Kafka Commit, nachdem sichergestellt wurde, dass alle Nachrichten tatsächlich verarbeitet werden ⇐ C#

[Guest]

Die Annahme ist also, dass das Thema Konsumentengruppe mit mehreren Verbrauchern mit mehreren Partitionen hat. Nun, vielleicht kann die gleiche Lösung mit einer Partition und einem Verbraucher für das Thema erforderlich sein, wenn Verbraucher asynchron lange lang lange Aufgaben an Schauspieler oder Threads delegiert. Der manuelle Verbraucher.Commit () oder Consumer.Commitasync () wäre erforderlich, um sicherzustellen /> Um dies zu erreichen, muss auch in Betracht gezogen werden, dass der festgelegte Offset in der Tat bedeutet, dass alle früheren Nachrichten in früheren Offsets nur einmal verarbeitet werden, aber sicher abgeschlossen sind. < /p>
Ich habe gehört Customized 'Committer' -Dienst, der beispielsweise sicherstellen kann, dass der Beförderungsantrag bei Offset 102 tatsächlich sicherstellt, dass dieser Dienst tatsächlich sicher ist, dass der Befehl Offset 102 sicher ist, indem alle Nachrichten vom aktuellen Offset (sagen wir sagen, er liegt bei 90) bis zum angeforderten Offset ((er 102) werden alle verarbeitet. Datenbank), um den festgelegten Verlauf zu halten und zu begehen, oder wenn dies Overkill und Kafka sind, bietet tatsächlich einige Funktionen in Bezug auf diese Art von Szenario.