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

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

7 ответов

14 просмотров

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

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

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

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

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

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

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

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

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

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

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

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

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

Подскажите, а есть vault lite или ченить такое?) А то нужен вольт для похода в вольт, но весит он ~500 мб) как-то многовато для парочки запросов ))
Alexandr Orloff
17
Всем привет, есть небольшая проблема Есть такой скрипт document.addEventListener('DOMContentLoaded', function () { const sliderTabs = document.querySelectorAll('.s...
A da
8
@go1337 @dblackCat Привет. Все ещё дрочусь с fastpanel. Добавил второй домен который должен смотреть в рут того же сайта, но так как это просто домен, а не сайт, я не могу ему...
Ross 🦴
9
До речі, в ево нема можливості чи якого розширення щоб з адмінки з телефона зайти і терміново щось в верстці поправити?
Женя
7
кто-нибудь пользуется тайм-трекерами во время работы? так много разных нагуглил, может есть что-то популярное
Lencore
8
Пацаны. Я разрабатываю софт для инвайтинга на телетон, и столкнулся с такой проблемой, в один из чатов не могу приглашать никого, не дает добавлять, в то же время через официа...
Kernel Panic
11
Скажите, а кому нужен Currency как отдельный плагин вместо полноценного ecommerce в OctoberCMS? Кто-то использует его уже или планирует в будущем? Может я что-то не понимаю?
Igor
13
Розмовами про Рево мені нагадали часи, коли шаблони правилися прямо в адмінці. Хто в курсі, чому відійшли від цієї практики, так блейд не працює? Доволі зручно ж було (інколи)
Женя
3
Всем добрый вечер, Рад оказаться в кругу единомышленников. Начинаю погружаться в мир .net веба. Зовут Ерасыл 🖖 У меня назрел вопрос: Какой процент проектов, прошедшие через в...
Ерасыл
6
Чому? Да тому що без GiT не уявляю нормального проекта а коли код в базі то то так собі
Dmytro Lukianenko
3
Карта сайта