Кака auto.offset.reset запрос

Question

Мой проект использует версию Kafka 0.10.2. Iam параметр enable.auto.commit = false и auto.offset.reset = последний в потребителе. Если потребитель перезапускается после обслуживания, он снова читает с первого смещения вместо ожидания последних сообщений смещения. Есть ли причины, почему это происходит? Правильно ли я понял настройки?

Мое требование - потребитель не должен автоматически фиксировать и должен читать только новые сообщения, помещенные в топи c, когда он активен.

Answer 1

То, что вы не выполняете автоматическую фиксацию, не гарантирует, что нет ручной фиксации.

В любом случае, auto.offset.reset=latest никогда не отправит группу потребителей в начало топи c. Похоже, что любой инструмент / библиотека Kafka, который вы используете, вызывает consumer.seekToBeginning вызов самостоятельно.