Всем привет. Подскажите пожалуйста, является ли Consumer без указания group.id

нормальной группой с единственным участником? Проблема в том, что я не могу получить оффсеты у таких косюмеров через AdminClient: запрос listConsumerGroupOffsets выдает пустой список. А очень нужно. Есть варианты?

11 ответов

25 просмотров

Группа это и есть место, где хранятся оффсеты, нет группы, нет и оффсета, но ничего не мешает хранить оффсеты в другом месте, в базке например, или таки использовать группу

Alexander-Fedyukov Автор вопроса
Дмитрий В
Группа это и есть место, где хранятся оффсеты, нет...

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

Alexander Fedyukov
на самом деле оффсеты хранятся в спецтопике. мне в...

группа вроде в любом случае создается, если не указана кастомная.

Alexander-Fedyukov Автор вопроса
Марат
группа вроде в любом случае создается, если не ука...

Да, что-то типа groupId=db960395-9b06-44e0-99f5-b3eac0bbcb0e. И вот от нее оффсеты не получить так как от обычной...

Alexander Fedyukov
Да, что-то типа groupId=db960395-9b06-44e0-99f5-b3...

Не получается достать имя группы ?

Alexander-Fedyukov Автор вопроса
Марат
Не получается достать имя группы ?

Получается. Но когда по ней вызываю AdminClient.listConsumerGroupOffsets, то получаю пустую коллекцию.

Alexander Fedyukov
Получается. Но когда по ней вызываю AdminClient.li...

а через консольную тулзу тоже не видит? kafka-consumer-groups.bat --command-config consumer.properties --bootstrap-server XXX:9093 --dry-run --describe --all-groups

не является. подключение консьюмера в составе консьюмер-группы и без неё - это разные механизмы

Alexander-Fedyukov Автор вопроса
Alexander-Fedyukov Автор вопроса

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

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

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