В Kafka manual commit — это процесс явного подтверждения потребителем (consumer) обработки сообщений, при котором разработчик самостоятельно контролирует, когда смещение (offset) сообщений фиксируется в Kafka.

По умолчанию Kafka может автоматически коммитить смещения через определённые интервалы времени (auto-commit). Однако manual commit позволяет:

Гарантировать, что смещение будет зафиксировано только после успешной обработки сообщения.
Избежать потери или повторной обработки сообщений при сбоях.

В Go-клиентах Kafka (например, sarama или confluent-kafka-go) manual commit обычно реализуется вызовом функции, которая сохраняет текущий offset после обработки сообщения.

Пример (псевдокод):

for msg := range consumer.Messages() {
    process(msg)
    consumer.MarkMessage(msg, "") // manual commit offset
}

Таким образом, manual commit даёт полный контроль над подтверждением обработки сообщений, что важно для обеспечения надёжности и консистентности данных.

Объясни понятие manual commit в Kafka