Πώς να κάνετε ώστε όλα τα γεγονότα μιας παραγγελίας να πηγαίνουν σε ένα μόνο partition του Kafka;

Για να διασφαλιστεί ότι όλα τα γεγονότα μιας παραγγελίας καταλήγουν σε μια ενιαία partition του Kafka, πρέπει να χρησιμοποιείτε ένα κλειδί (key) κατά την αποστολή μηνυμάτων, το οποίο ταυτοποιεί με μοναδικό τρόπο την παραγγελία.

Το Kafka χρησιμοποιεί το κλειδί για τον υπολογισμό της partition μέσω μιας συνάρτησης κατακερματισμού (hash). Αν για όλα τα γεγονότα μιας παραγγελίας χρησιμοποιείται το ίδιο κλειδί (π.χ., order_id), τότε αυτά θα καταλήξουν στην ίδια partition.

Παράδειγμα σε Go με sarama (δημοφιλής πελάτης Kafka):

producer.Input() <- &sarama.ProducerMessage{
    Topic: "orders",
    Key:   sarama.StringEncoder(orderID), // orderID — αναγνωριστικό παραγγελίας
    Value: sarama.StringEncoder(eventData),
}

Έτσι, διασφαλίζεται ότι όλα τα γεγονότα με το ίδιο κλειδί θα βρίσκονται στην ίδια partition, κάτι που είναι σημαντικό για την διατήρηση της σειράς και τη συνοχή.