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

есть топик. в нем десять партиций. каждая партиция. начало примерно 16миллионов (оффсет). конец, 21 миллион. итого я ожидаю суммарно получить где то 50 миллионов записей из нее.

начинаем шагать. и снимать периодически показания о текущем оффсете по партициям. ну оно как бы равномерно уменьшается.

прочел 1000 сообщений, увеличилось на 1000. прочел еще 2000 сообщений текущий оффсет увеличился на 2000. прочитал еще 1000 а текущий оффсет увеличился на... 3 миллиона. ШТО? читаем дальше текущий оффсет увеличился на 1к, там 2к,3к потом снова бабах и на полмиллиона. и так далее.

собссно вопрос. почему не равномерно? что за фигня?


у конфигурации установлено автокоммит. может ли быть такое что автокоммит шлепает больше чем выкачал? ну это же бред какой то.