Как связать тему кафки с веб-конечной точкой с помощью пакета Faust Python?

У меня есть простое приложение, с двумя функциями, одна для прослушивания темы, а другая для веб-конечной точки. Я хочу создать потоковую передачу событий на стороне сервера (SSE), то есть text / event-stream, чтобы на стороне клиента я мог слушать ее с помощью EventSource. У меня есть следующий...