косьюмера, определил его в группу, все ок приходят сообщения, рестартанул консьюмера и сообщения больше не приходят. Тут написанно, что надо обнулить счетчик CURRENT_OFFSET. Как это сделать из python-kafka или confluents-kafka? Или есть какой то более прямой путь и я что то делаю не так
В Кафке можно сбросить текущий офсет, для твоей группы консюмеров
Обсуждают сегодня