Kā notiek ziņojumu apstrādes apstiprināšanas process Kafka?

Apache Kafka apstiprinājums ziņojumu apstrādei (acknowledgment) tiek veikts, izmantojot offset commit mehānismu.

Proces:

1. Patērētājs saņem ziņojumu no tēmas.
2. Veiksmīgi apstrādājot ziņojumu, patērētājs ieraksta (commit) šī ziņojuma offsetu.
3. Kafka saglabā informāciju par pēdējo apstiprināto offsetu katrai patērētāju grupai.

Go valodā, izmantojot Kafka klientu (piemēram, sarama vai confluent-kafka-go), apstiprinājums var būt automātisks vai manuāls:

• Automātisks commit — klients periodiski nosūta informāciju par pēdējo apstrādāto offsetu.
• Manuāls commit — izstrādātājs tieši izsauc commit metodi pēc ziņojuma apstrādes, tas nodrošina lielāku kontroli un uzticamību.

Piemērs ar sarama (manuāls commit):

consumer, _ := sarama.NewConsumerGroup(brokers, groupID, config)
// Ziņojumu apstrādes funkcijā, pēc apstrādes:
session.MarkMessage(message, "") // atzīmē ziņojumu kā apstrādātu
// Pēc apstrādes pabeigšanas izsauc Commit()