Πώς μπορούμε να προσδιορίσουμε το γεγονός ότι ένα μήνυμα έχει διαβαστεί στο Kafka;

Στο Kafka, το γεγονός ότι ένα μήνυμα έχει διαβαστεί καθορίζεται από τις μετατοπίσεις (offsets) στις partition του θέματος. Κάθε καταναλωτής (consumer) παρακολουθεί μέχρι ποια μετατόπιση έχει διαβάσει σε κάθε partition.

Για να προσδιορίσετε ότι ένα μήνυμα έχει διαβαστεί, πρέπει:

• Να βεβαιωθείτε ότι ο καταναλωτής έχει επεξεργαστεί επιτυχώς το μήνυμα.
• Να επιβεβαιώσετε (commit) τη μετατόπιση αυτού του μηνύματος στο Kafka, δηλαδή να ενημερώσετε τον broker ότι όλα τα μηνύματα μέχρι αυτή τη μετατόπιση έχουν επεξεργαστεί.

Στη Go, χρησιμοποιώντας έναν πελάτη Kafka (π.χ., sarama ή confluent-kafka-go), μπορείτε να κάνετε ρητά commit τις μετατοπίσεις μετά την επεξεργασία των μηνυμάτων. Αν η μετατόπιση επιβεβαιωθεί, το μήνυμα θεωρείται διαβασμένο και δεν θα παραδοθεί ξανά σε αυτόν τον καταναλωτή.

Παράδειγμα με sarama (απλουστευμένο):

consumer.MarkMessage(msg, "") // Σημειώστε το μήνυμα ως διαβασμένο
consumer.CommitOffsets()       // Επιβεβαιώστε τις μετατοπίσεις

Έτσι, το γεγονός ότι ένα μήνυμα έχει διαβαστεί είναι μια επιτυχής commit της μετατόπισης στο Kafka.