Ինչպես է կատարվում հաղորդագրությունների մշակման հաստատման գործընթացը Kafka-ում?

Apache Kafka- ում հաղորդագրությունների մշակման հաստատումը (acknowledgment) իրականացվում է offset commit մեխանիզմի միջոցով:

Պրոցեսը՝

1. Կոնսումատորը ստանում է հաղորդագրություն թեմայից:
2. Հաջող մշակելուց հետո կոնսումատորը գրանցում է (commit) այդ հաղորդագրության offset-ը:
3. Kafka-ն պահպանում է վերջին հաստատված offset-ի մասին տեղեկատվությունը յուրաքանչյուր կոնսումատորային խմբի համար:

Go-ում, օգտագործելով Kafka հաճախորդ (օրինակ, sarama կամ confluent-kafka-go), հաստատումը կարող է լինել ավտոմատ կամ ձեռքով:

• Ավտոմատ commit — հաճախորդը ժամանակ առ ժամանակ ուղարկում է վերջին մշակված offset-ի մասին տեղեկատվություն:
• Ձեռքով commit — ծրագրավորողը բացահայտորեն կանչում է commit մեթոդը հաղորդագրության մշակումից հետո, ինչը ապահովում է ավելի մեծ վերահսկողություն և հուսալիություն:

Օրինակ sarama-ով (ձեռքով commit):

consumer, _ := sarama.NewConsumerGroup(brokers, groupID, config)
// Հաղորդագրությունների handler-ում, մշակելուց հետո:
session.MarkMessage(message, "") // նշում է հաղորդագրությունը որպես մշակված
// Մշակման ավարտից հետո կանչվում է Commit()