Может Кафка не поняла что это тот же самый

консумер ? Есть какие то еще критерии кроме consumer group id по которым брокер принимает решенеи по оффсету ?

7 ответов

19 просмотров

может быть ситуация, что для группы записан некий оффсет, но этот офсет давно прошел, например потому что группа давно не разбирала топик (был долгий простой) вот группа коннектится, и у нее тут два варианта - читать с последнего сообщения топика - читать с начала топика вот у вас видимо коньюмер сконфигурен читать с начала в этом случае но я джун в кафке, поэтому могу быть не прав

Valeriy-Nebo Автор вопроса
Igor
может быть ситуация, что для группы записан некий ...

В том то и дело что простоя на первый взгляд небыло, было потребление . Т.е. теретически ретешне консумер офстеа никак не могу наступить (он же по дефолту 24 часа или больше )

Valeriy-Nebo Автор вопроса
Igor
может группу тогда переименовал?

Нет , такое произошло сразу на нескольких топиках, с разными консумерами .

Igor
может быть ситуация, что для группы записан некий ...

У некоторых консюмеров видел политику, если они были перезапущены без предварительной остановки (аналог аварийного перезапуска), то консюмер автоматом сбрасывает офсет консюмер группы на определённое состояние (по умолчанию обычно стоит earliest) и в этот момент как раз может быть подобная ситуация

Юра Ходырев
У некоторых консюмеров видел политику, если они бы...

хм, а как они понимают что они грохнулись аварийно? стейт консьюмера это же офсет, а он хранится не на самом консьюмере, поэтому не понятно, почему бы не начать с офсета

Igor
хм, а как они понимают что они грохнулись аварийно...

Тут у меня никаких гипотез к сожалению нет. Я только замечал, что если перед перещагрузкой кафка коннект кластера, все что в нем живёт предварительно ставлю на паузу и потом начинаю тех работы, то последующий запуск, после работ, не приводит к этой проблеме

Похожие вопросы

Обсуждают сегодня

Добрый вечер, Пока не совсем понимаю как наладить общение между телеграм ботом и ПО для работы с сим боксом. По самому боту так понял: - Нужен некий баланс, который можно поп...
Magic
6
сделал сайт, прикрутил в боте сайт, и виджет логина. как автоматически логинить пользователя в аккаунт(телеграм), при входе с бота?
Александра Чернивецкая
5
Объясните, пожалуйста, почему компилятор ругается на использование в условии неинициализированной переменной: int x; Task.Run(async () => { x = await somefunc(); }).Wait...
Александр
5
Ребят, подскажите, пожалуйста, почему в префиксе к ассетам, которые генерируются через фильтр | theme в шаблоне, стал вдруг появляться index.php? Вот так выглядит ссылка на а...
Виталий
1
Всем привет. Ребята, подскажите, пожалуйста. у ботов есть ограничение на отправку сообщений - 30 сообщений в секунду, эти ограничения накладываются на все сообщения? или на со...
Artem Stormageddon
4
Блин, ребята, сори за тупые вопросы. А можно ли как-то открыть вебапку по нажатию на кнопку в меню(которое появляется слева, команды)?
Artem Stormageddon
3
а плаксы из-под питона умеют только в комфортных условиях что-то выдавить из себя?)
Lencore
9
Но, может, есть уже проверенная? Наши требования такие: 1. Сообщения должны приходить из Инста в CRM оду 2. Должна быть возможность подключить несколько экаунтов Инстаграм. Р...
Alexander Sharoiko MSE / Александр Шаройко
13
Это может быть все-таки не флудвейт? у меня ботфазер принимает изменения и отображает даже что они изменились, на видео видно что он прислал якобы уже измененное описание, н...
OVERLINK
13
Коллеги, может знает кто, можно ли цвет бейджа счётчика в BackendMenu менять без бубнов?
Alex Blaze
3
Карта сайта