Como conectar o tópico kafka ao endpoint da web usando o pacote Faust Python?
Eu tenho um aplicativo simples, com duas funções, uma para ouvir o tópico e outra para o endpoint da web. Desejo criar SSE (fluxo de eventos do lado do servidor), ou seja, texto / fluxo de eventos, para que no cliente final possa ouvi-lo usando EventSource. Eu tenho o seguinte código por enquanto,...