Laufzettel in Kafka (Themen der Reihe nach aufrufen) ⇐ C#

[Anonymous]

Stellen Sie sich vor, ich hätte ein Chronographensystem, dessen Reihenfolge für mich wichtig ist. Ich habe zum Beispiel einen Produzenten, der Daten mithilfe von Confluent.Kafka in c# zum ersten Thema in Kafka pusht.
Dann habe ich einen Konsumenten Das hört auf den ersten Verbraucher. Nachdem alles korrekt ist, rufe ich das 2. Thema auf. Nun, ich habe eine Validierung, um das nächste Ziel auszuwählen. Würde meine erste Bedingung wahr sein, rufe ich das 3. Thema auf, andernfalls rufe ich das 4. auf. Außerdem benötige ich eine Entschädigung für jeden Anruf, wenn der dritte ein Problem hat, Rollback und zurück zum 2. zurück zum 1. Gibt es eine Best Practice für diesen Ansatz? Ich kenne Routing-Slip mit Masstransit, geben Sie uns diese Möglichkeit, indem Sie Aktivitäten verwenden; Allerdings habe ich keine Ahnung, ob es möglich ist, es in Kafa oder einer anderen Alternative zu verwenden, sonst muss ich etwas manuell implementieren.