Почему Consumer.position() > (consumer.endOffset(...) + 1) в Kafka? ⇐ JAVA

[Anonymous]

У меня есть код, который распечатывает Consumer.endOffsets() и текущее Consumer.position() в обратном вызове void onPartitionsAssigned(Collection partitions).
Я обнаружил, что конечное смещение позиции потребителя > для раздела + 1, но я не знаю, почему.
Я фиксирую смещения вручную как часть транзакции для семантики ровно один раз:

Код: Выделить всё

consumer.commitSync(singletonMap(partition, new OffsetAndMetadata(lastOffset + 1)))

TTL для смещений больше, чем у событий, поэтому теоретически я мог бы получить 0 в качестве конечного смещения, где позиция > 0. Это нормально и объяснимо.
Что мне не хватает?
Kafka v3.1.0>

Подробнее здесь: https://stackoverflow.com/questions/798 ... 1-in-kafka