У меня есть опрос потребителей из подписанной темы. Он потребляет каждое сообщение и выполняет некоторую обработку (в течение нескольких секунд), переходит к другой теме и фиксирует смещение. Всего 5000 сообщений, перед перезапуском -...

Я новичок в мире kafka и пытаюсь сделать следующее для потребителя kafka в python получить список всех тем о кафках. получить список тем, на которые подписался потребитель. подписывайтесь на новые темы (на которые еще не подписывались)....