В настоящее время я работаю над Apache Kafka, используя библиотеку go / golang. У меня есть некоторые сомнения относительно потребителя и его API.
Я использую API паузы и возобновления работы библиотеки и выполняю ручные коммиты. Допустим, я отправляю 100 сообщений, и без фиксации я приостановил работу потребителя и затем возобновил его. Я заметил, что он не использовал эти 100 сообщений снова, но начал потреблять последние сообщения. Это ожидаемое поведение? Если да, есть ли способ снова использовать эти 100 сообщений.
Когда я возобновляю работу потребителей, после некоторой обработки я выполняю фиксацию вручную. Я заметил зафиксированное смещение возврата -1001 для раздела. Я не могу понять, почему это происходит и что это значит? Я потерял все данные или произошел сбой при фиксации?
Может кто-нибудь объяснить мне auto.offset.reset - самый последний и самый ранний?
Спасибо