Вопросы с тегом «apache-kafka»

9
Кафка: постоянно получает FETCH_SESSION_ID_NOT_FOUND

Я постоянно получаю FETCH_SESSION_ID_NOT_FOUND. Я не уверен, почему это происходит. Может кто-нибудь порадовать меня здесь, в чем проблема и как это отразится на потребителях и брокерах. Журнал Сервера Кафки: INFO [2019-10-18 12:09:00,709] [ReplicaFetcherThread-1-8][]...

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

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