როგორ დავრწმუნდეთ, რომ ყველა შეკვეთის მოვლენები ერთ Kafka განყოფილებაში მოხვდება?

კითხვების სერიაში, რათა ყველა მოვლენა ერთ შეკვეთასთან დაკავშირებული, ყველა შეტყობინება უნდა იყოს გამოგზავნილი ერთგვარი გასაღვით (key), რომელიც ზუსტად იდენტიფიცირებს შეკვეთას.

Kafka იყენებს ამ გასაღებს ჰეშ-ფუნქციის საშუალებით ნაწილების გამოთვლისთვის. თუ ყველა მოვლენისთვის ერთსა და იმავე გასაღებს (მაგ., order_id) გამოიყენებთ, ისინი ერთ ნაწილში მოხვდებიან.

მაგალითი Go-ში sarama-ს გამოყენებით (პოპულარული Kafka კლიენტი):

producer.Input() <- &sarama.ProducerMessage{
    Topic: "orders",
    Key:   sarama.StringEncoder(orderID), // orderID — შეკვეთის იდენტიფიკატორი
    Value: sarama.StringEncoder(eventData),
}

ასე, ყველა მოვლენა ერთ გასაღთან ერთად ერთ ნაწილში იქნება, რაც მნიშვნელოვანია წესრიგიანი დამუშავებისა და კონსისტენციისთვის.