Чӣ тавр ҳамаи ҳодисаҳои як фармоиш ба як партисияи Kafka ворид шаванд?

Каб гарантаваць, што ўсе падзеі па адным заказе трапляюць у адну партыцыю Kafka, неабходна выкарыстоўваць ключ (key) пры адпраўцы паведамленняў, які дакладна ідэнтыфікуе заказ.

Kafka выкарыстоўвае ключ для вылічэння партыцыі праз хэш-функцыю. Калі для ўсіх падзей аднаго заказу выкарыстоўваць адзін і той жа ключ (напрыклад, order_id), яны трапяць у адну і тую ж партыцыю.

Прыклад у Go з выкарыстаннем sarama (папулярны кліент Kafka):

producer.Input() <- &sarama.ProducerMessage{
    Topic: "orders",
    Key:   sarama.StringEncoder(orderID), // orderID — ідэнтыфікатар заказу
    Value: sarama.StringEncoder(eventData),
}

Такім чынам, гарантуецца, што ўсе падзеі з аднолькавым ключом будуць у адной партыцыі, што важна для парадкавай апрацоўкі і кансістэнцыі.