Bagaimana menghubungkan topik kafka dengan endpoint web menggunakan paket Faust Python?

Saya memiliki aplikasi sederhana, dengan dua fungsi, satu untuk mendengarkan topik dan lainnya untuk titik akhir web. Saya ingin membuat streaming acara sisi server (SSE) yaitu teks / event-stream, sehingga pada klien saya dapat mendengarkannya menggunakan EventSource. Saya memiliki kode berikut...