Sicherstellen, dass nur wenige Nachrichten in einem bestimmten Nachrichtensatz bestellt werden

Question

Angenommen, ich habe 51 von MobileApp produzierte Nachrichten.

Ich möchte, dass 51. msg sollte den Anwendungsserver treffen, nachdem alle 50 verarbeitet werden. aber ich brauche keine Bestellung für andere 50 msgs. Sie können in beliebiger Reihenfolge treffen (Sollte parallel sein).

Derzeit verwende ich Kafka als Nachrichtenbroker.

große Einschränkung: - ich keine Callback-Mechanismus auf mobilen App 51th Nachricht setzen können nur zu geben, nachdem ich 50. Nachricht empfangen.

Irgendwelche Ideen um diese oder Verbindungen/Zeiger ??

Answer 1

Wenn Sie (synchron mit den Commits) die 51 Nachrichten der Reihe nach senden und den Partitionierer verwenden können, um alle Nachrichten in einer Sequenz an dieselbe Partition zu senden (vielleicht indem Sie die Benutzer-ID des Schlüssels der Nachricht setzen), können Sie sicher lesen diese Nachrichten in der Reihenfolge.