Jak połączyć temat Kafka z punktem końcowym sieci za pomocą pakietu Faust Python?

Mam prostą aplikację z dwiema funkcjami, jedną do słuchania tematu i drugą do punktu końcowego w sieci. Chcę utworzyć strumieniowe przesyłanie zdarzeń po stronie serwera (SSE), tj. Strumień tekstowy / zdarzeń, aby po stronie klienta mógł mnie słuchać za pomocą EventSource. Mam na razie następujący...