Привет! подскажите, если консьмера с консьюмер группой больше нет, кафка

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

5 ответов

27 просмотров
𝕀𝕍- Автор вопроса

offsets.retention.minutes ?

Если у тебя при этом консумеры слушают одни и те же топики то можно и без консумергруппы при условии что ее отсутсвие не сломает функционал. При этом если в топике данные заэкспайрятся то оффсет при подключении сбросится до самого свежего

𝕀𝕍- Автор вопроса
Solyar
Если у тебя при этом консумеры слушают одни и те ж...

да, одни, т.е. не указывать консьюмер группу тоже вариант? я так понимаю даже без указания группы брокер идентифицируется и для него хранится офсет верно?

𝕀𝕍
да, одни, т.е. не указывать консьюмер группу тоже ...

Ну ты в при подключении продюссеру указываешь топик на который смотреть надо. Он подключается и все на этом история заканчивается. Кафка проследит чтобы ты подключился куда надо и сбросит просроченные записи (если они истекли по retention) и позицию курсора оффсета

𝕀𝕍- Автор вопроса
Solyar
Ну ты в при подключении продюссеру указываешь топи...

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

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

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

Но, может, есть уже проверенная? Наши требования такие: 1. Сообщения должны приходить из Инста в CRM оду 2. Должна быть возможность подключить несколько экаунтов Инстаграм. Р...
Alexander Sharoiko MSE / Александр Шаройко
8
Это может быть все-таки не флудвейт? у меня ботфазер принимает изменения и отображает даже что они изменились, на видео видно что он прислал якобы уже измененное описание, н...
OVERLINK
13
Я правильно понимаю что нет способов получить список ожидающих заявок на вступление в группу с помощью бота из mtproto?
Шамиль Прилов
7
Добрый день. Мне посоветовали обратиться к вам в чат за помощью. Ситуация описана на скрине. Как мне сказали, мне на бота навесили флудвейт. Есть ли возможность снять его ра...
OVERLINK
7
всем привет помогите пожалуйста используя CDN (GCP) у игроков из вьетнама загружается конфиг (размер 999 bytes) загружается 5 и более минут н а других CDN сервисах такой пробл...
Andrew Krw.
1
Просто по очереди выпиливаешь на ручной маппинг? По методу за раз
Andrii Kurdiumov
7
Приветствую. А не подскажете какие ограничения есть на использования api метода setMyName ? Несколько раз сменил имя бота и получил бан на 2 месяца на смену имени.
Slick Slack
8
Привет, коллеги! Возникла задача ограничить максимальный размер вложений для определённых расширений, например, чтобы для изображений лимит был 10 МБ, а для видео — 100 МБ. Ог...
Andro
1
Всем привет! Взялся портировать модули на 18 версию, лезет _logger.log(log_level, 'no translation language detected, skipping translation %s', frame, stack_info=True) А чт...
Max Lit
3
Доброе утро, а кто то делал Google аналитику через php ? curl_setopt($ch, CURLOPT_NOSIGNAL, true); Это должно быть async без ожидания ответа. Вообще php нормально с таким с...
Max Dubovsky
9
Карта сайта