Comment connecter un sujet kafka avec un point de terminaison Web à l'aide du package Faust Python?

J'ai une application simple, avec deux fonctions, l'une pour écouter le sujet et l'autre pour le point de terminaison Web. Je veux créer un flux d'événements côté serveur (SSE), c'est-à-dire du texte / flux d'événements, afin que du côté client, je puisse l'écouter en utilisant EventSource. J'ai le...