Здравствуйте,ППодскажите по кафке: создал нового консумера на существующий топик, сам консумер

груп виден, но видно что он ничего не читает и current-offset не назначен даже

сообщения в топик поступают и другой консумер их успешно читает, куда копать - как дебажить?

root@fmk-kafka-analytics-1:/opt/kafka/bin# ./kafka-consumer-groups.sh --describe --group PySparkKafkaToCH --bootstrap-server localhost:9092

GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
PySparkKafkaToCH stat.api_query_log 5 - 27991971 - consumer-PySparkKafkaToCH-1-1f92f08f-cd81-42ab-8aa0-4f443dc6786a /ip consumer-PySparkKafkaToCH-1


при этом state = stable

2 ответов

8 просмотров

а вроде в приведенном выхлопе у вас 1 консьюмер представлен? а вы пишете, что в той же группе есть другой, который все читает? или тот, второй - в другой группе?

Егор-Пересада Автор вопроса
Andrey K.
а вроде в приведенном выхлопе у вас 1 консьюмер пр...

Уже не актуально, проблема была в том что Спарк по умолчанию не коммитит в кафку ничего

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

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

Я хочу запустить свой проект в тг. Что-то между пирамидой и майнилкой. Еще подобного ничего не было. Уникальная идея. Нужен именно не бот, а приложение. С ввод, выводом тон...
Павел А.
6
Всем доброго вечера! Хочу поделиться своим злоключением с человеком, который, как оказалось сюда тоже скидывал свое резюме. Жаль, что я вашу группу не нашел раньше… человек ки...
Роман Ахмедзянов
4
Привет, кто может сделать юзербота с апи? Задачи: - создавать группы - создавать каналы - задавать для созданных каналов аватарку или эмоджи, имя группы - добавлять в группы...
Lencore
11
господа, когда у вас в боте есть локализация (ру + англ, остальные языки пока не планируются), вы на первом старте как с языком решаете вопрос: смотрите на language_code приле...
Denis 🐍|👑 | darling! 🥰
5
Я колись ставив гуглу антиспам 3.0, може і норм, але мені не дуже зайшло. Теж думав тиждень, що його і куди. Зупинився на трех варіантах відразу всі три і включив 1. Перевір...
𝓔𝓾𝓰𝓮𝓷𝓮𝓥 J
2
Всем привет, Добавил в плагин определение user agent public function registerMarkupTags() { return [ 'filters' => [ 'staticPage' => ['RainLab\Pages\Cl...
John Norton Kruger
3
А чего при переходе с 2 на 3 все что в билдере сделано тютю?
Денис Александрович
5
Кому нибудь нужен плагин для генерации метатегов? А если нужен что бы вам хотелось в нем видеть?
Black Cat
3
Портфолио: Зовут меня Александр, мне 36 лет. Город Пушкино. Общий рабочий стаж: ~14 лет Уровень квалификации: Senior Full-stack developer Где прочесть мой код? https://github....
Magic
10
где собака, админ группы? нычкуется и боится проявить волю, в толерантность еще не наигрался? @yelizariev
Ognezar
61
Карта сайта