¿Cómo conectar el tema kafka con el punto final web usando el paquete Faust Python?

Tengo una aplicación simple, con dos funciones, una para escuchar el tema y otra para el punto final web. Quiero crear la transmisión de eventos del lado del servidor (SSE), es decir, texto / evento-transmisión, para que en el extremo del cliente pueda escucharlo usando EventSource. Tengo el...