Пацаны, как пинговать кафку/топик на наличие признаков жизни если у

топика партиция 1 и она занята?

Запустить консьюмера?

Есть 1 партиция, есть 1 консьюмер который оттуда читает, они в общем работают долго и счастливо Нужно только отслеживать доступность топика, и предпринять определенные действия, но знаю что если я добавлю ещё одного консюмера который будет подключаться к топику чтобы проверить что он доступен, он сделать это не сможет так как партиция занята другим консьюмером

Использовать консьюмер группы разные. Создать группу типа heartbeat и добавить права если ACL есть

А в чем проблема сделать консьюмера с другой группой?

This

группы добавлять нужно на уровне брокера?

Нет, при старте консьюмера в конфиге указывается group.id

А, это хорошо, спасибо😘

Если нет ACL то группы при вызове создаются

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

Жив или нет топик? В смысле не удалён ли он?

Проверка на доступность

А чего бы ему не крутиться постоянно? Зачем вот эти все шедулеры?

Вообще идея была подключиться посмотреть отключиться, и так в заданный период.. Но можно чтобы и постоянно работало, только наткнулся на серьёзное ограничение, Крч, в случае не доступности брокера кафки клиент не бросает ошибку а просто выводит в терминал broker maybe not available

Ну вообще в топике будут млн данных, как то это обрабатывать и не хотелось

Сделай топик только для пинга. И не надо мульен данных