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

Question

Я пишу потребителю кафки, используя механизм опроса, в котором я получаю 100 сообщений за опрос. После использования сообщений я фиксирую смещение вручную по одному. При фиксации смещения иногда я получаю сообщение об ошибке из одного сообщения из 100 сообщений. Остальные смещения фиксируются успешно.

Offsets
1,2,3,4,5,6,7,....100

Допустим, смещение 5 зафиксировано неудачно, но за исключением смещения 5 все смещения зафиксированы успешно.

Итак, что в этом случае происходит с ошибкой смещения фиксации? Поскольку смещение перемещается последовательно, получу ли я смещение при неудачной фиксации в следующем опросе?

Мое первичное расследование показывает, что в следующем опросе считывается ошибочное смещение. Нужна экспертиза взгляда на это.

Answer 1

Не требуется фиксировать каждое смещение индивидуально. И если вы фиксируете смещение X, это означает, что все меньшие смещения также фиксируются.