Мой раздел Kafka получил 20 смещений. У меня есть группа потребителей из 5 подписчиков. Мой вопрос: можно ли гарантировать, что первые 5 смещений будут прочитаны потребителем 1, после успешного чтения следующие 5 смещений будут прочитаны потребителем 2 и т. д.? Если это невозможно, то есть ли для этого какой-либо инструмент/технология с открытым исходным кодом?
Зачеты Kafka и проблема группы потребителей
comment
Я думаю, что под смещением вы имеете в виду сообщения. У вас может быть несколько разделов для темы, и каждый потребитель в группе читает из отдельного раздела. У вас может быть своя собственная логика, чтобы заблокировать других потребителей от чтения, пока первый не закончит.
- person asolanki schedule 29.11.2018
Ответы (1)
Два потребителя, принадлежащие к одной и той же группе потребителей, не могут читать из одного раздела. Если имеется только один раздел, один потребитель будет потреблять все 20 смещений, а остальные потребители будут бездействовать, пока не будет добавлен новый раздел.
person
Nishu Tayal
schedule
29.11.2018
