Я разрабатываю REST API во Flask , получая данные от Кафки в режиме реального времени .
Мне нужно использовать записи из Кафки в фоновом режиме иобновлять данные каждые 2 секунды с записями одновременно. Я пытался использовать потоки с глобальной очередью записей, чтобы добавить записи из kafka и показать в таблице данных с помощью функции ajax , но это не рабочее свойство.
Как я могу потреблять записи в фоновом режиме из kafka и показывать их в Datatable во Flask одновременно?.