Тұтынушы әртүрлі режимдерде offset-ті қалай commits етеді?

Go тілінде Kafka-мен жұмыс істегенде, тұтынушының оффсеттерін әртүрлі режимдерде сақтауға болады, олар жеткізу кепілдігі мен өнімділікке әсер етеді:

• Автоматты коммит (Auto Commit): оффсет автоматты түрде белгіленген интервалда сақталады. Бұл ыңғайлы, бірақ ақаулар кезінде хабарламаларды қайта өңдеуге әкелуі мүмкін.

• Ручной синхронды коммит (Manual Sync Commit): хабарламаны өңдегеннен кейін, коммит әдісі шақырылады, ол растау алынғанша тоқтайды. Бұл оффсеттің сақталуын кепілдейді, бірақ өнімділікті төмендетеді.

• Ручной асинхронды коммит (Manual Async Commit): оффсет фондық режимде сақталады, өңдеуді тоқтатпайды. Жылдамырақ, бірақ ақау кезінде коммит жоғалуы мүмкін.

Sarama кітапханасын пайдаланып, ручной коммиттің мысалы:

consumer.MarkMessage(msg, "") // Хабарламаны өңделген деп белгілейміз
err := consumer.CommitOffsets() // Синхронды коммит
if err != nil {
    // қате өңдеу
}

Режим таңдау сенімділік пен өнімділік талаптарына байланысты.