Wie verbinde ich ein Kafka-Thema mit dem Web-Endpunkt mithilfe des Faust Python-Pakets?

Ich habe eine einfache App mit zwei Funktionen, eine zum Anhören von Themen und eine für Webendpunkte. Ich möchte serverseitiges Ereignis-Streaming (SSE) erstellen, dh Text- / Ereignis-Stream, damit ich es auf Client-Seite mit EventSource abhören kann. Ich habe vorerst den folgenden Code, in dem...