Как consumer committed offset в разных режимах?

В Go при работе с Kafka consumer offset можно коммитить в разных режимах, которые влияют на гарантии доставки и производительность:

• Автоматический коммит (Auto Commit): offset коммитится автоматически через заданный интервал. Это удобно, но может привести к повторной обработке сообщений при сбоях.

• Ручной синхронный коммит (Manual Sync Commit): после обработки сообщения вызывается метод коммита, который блокирует выполнение до подтверждения. Гарантирует, что offset сохранён, но снижает производительность.

• Ручной асинхронный коммит (Manual Async Commit): offset коммитится в фоне, не блокируя обработку. Быстрее, но возможна потеря коммита при сбое.

Пример ручного коммита с использованием библиотеки sarama:

consumer.MarkMessage(msg, "") // Помечаем сообщение как обработанное
err := consumer.CommitOffsets() // Синхронный коммит
if err != nil {
    // обработка ошибки
}

Выбор режима зависит от требований к надёжности и производительности.