Implémentation de sagas avec Kafka

Question

J'utilise Kafka pour l'approvisionnement d'événements et je suis intéressé par la mise en œuvre de sagas en utilisant Kafka. J'ai fait quelques recherches mais je n'ai rien trouvé sur le sujet. Il y a beaucoup d'informations sur Sagas mais je pense qu'une implémentation utilisant Kafka pourrait impliquer plusieurs complexités. Toutes les meilleures pratiques sur la façon de faire cela? Le modèle de commandant mentionné here semble proche de l'architecture que j'essaie de construire mais les sagas ne sont mentionnées nulle part dans la présentation.

Answer 1

Cette conférence de cette année DDD eXchange est la meilleure que je suis tombé sur modèle Process WRT Directeur/Saga dans les systèmes événementiels/CQRS: https://skillsmatter.com/skillscasts/9853-long-running-processes-in-ddd (nécessite l'inscription à un compte gratuit pour visualiser)

Le démo montré il vit sur github: https://github.com/flowing/flowing-retail

Je l'ai donné une rotation et je l'aime bien. Je recommande de regarder la vidéo en premier pour préparer le terrain.

Bien que l'approche présentée soit agnostique avec le bus de messages, la démo utilise Kafka pour que le gestionnaire de processus envoie des commandes et écoute des événements provenant d'autres contextes liés. Il n'utilise pas Kafka Streams mais je ne vois pas pourquoi il ne pourrait pas être branché sur une topologie Kafka Streams et faire partie de l'architecture plus large comme celle décrite dans la présentation de Commander que vous avez référencée.

J'espère approfondir cette question pour nos propres besoins, alors n'hésitez pas à lancer un fil sur la liste de diffusion des utilisateurs de Kafka, c'est un bon endroit pour collaborer sur de tels modèles. Un espoir qui aide :-)