Sobes.tech
Senior
60

Se, ao ler um lote de 50 mensagens, as últimas 5 falharem com um erro, o que acontecerá com o deslocamento?

Empresas quando solicitadas
Octo

Resposta da IA

sobes.tech IA

Если при чтении батча из 50 сообщений последние 5 упали с ошибкой, то поведение с оффсетом зависит от механизма подтверждения (commit) в используемой системе (например, Kafka).

  • Если оффсет подтверждается после успешной обработки всего батча, то оффсет не будет сдвинут, и при повторном чтении эти 5 сообщений будут прочитаны снова.
  • Если подтверждение происходит по каждому сообщению, то оффсет сдвинется только до последнего успешно обработанного сообщения.

Таким образом, обычно оффсет не смещается на сообщения с ошибками, чтобы обеспечить повторную попытку их обработки и избежать потери данных.