консумеров и 2 топика по 2 партиции
2) коммиты делаются вручную через commitSync(offset)
3) в топиках есть данные и данные законсумлены
если прочитать __consumer_offsets партицию где хранится состояние моей группы подписки
то видно что по всем партициям для моей группы есть записи с коммитами.
4) все работает нормально, но внезапно один процесс с консумером падает
происходит ребаланс
5) несмотря на то что у группы подписки есть коммиты по всем партициям
происходит вычитывание всех имеющихся данных по некоторым партициям моих топиков
6) кафка версии 0.11.0.1-cp1
может кто сталкивался ?
А клиент?
Обсуждают сегодня