#apache-kafka
Вопрос:
Может быть, это дублирующий вопрос. Допустим, у меня есть 1-100 сообщений, и их обработка выполняется в отдельных процедурах go. Все сообщения были отправлены, за исключением четырех сообщений 55,56,57,58 из-за какой-то проблемы, и последнее отправленное сообщение-100. Я перезапустил машину, в которую входят как потребитель, так и брокер кафки. Когда потребитель запускается, я снова получаю сообщения начиная с 55 лет. Когда это произойдет? Я ожидаю, что всегда буду получать последнее отправленное сообщение 1. В этом случае это будет любое сообщение выше 100.
autoOffsetReset = самый ранний, число разделов = 1 количество потребителей = 1 автоматическая фиксация= выключено
Комментарии:
1. Если вы успешно зафиксировали смещение 100, неясно, как ваш потребитель вернется к 55 для того же идентификатора группы