Bir buyurtmadagi barcha voqealarni Kafka'da bitta partitsiyaga qanday qilib yuborish mumkin?

Kafka, bir buyurtma bo'yicha barcha voqealarni bir xil partiyaga tushirish uchun, xabar yuborishda buyurtmani aniq identifikatsiya qiladigan kalit (key) ishlatish kerak.

Kafka kalitni hash funktsiyasi orqali partiyani hisoblash uchun ishlatadi. Agar bir buyurtmadagi barcha voqealar uchun bir xil kalit (masalan, order_id) ishlatilsa, ular bir xil partiyaga tushadi.

Go tilida sarama (mashhur Kafka mijoz) bilan misol:

producer.Input() <- &sarama.ProducerMessage{
    Topic: "orders",
    Key:   sarama.StringEncoder(orderID), // orderID — buyurtma identifikatori
    Value: sarama.StringEncoder(eventData),
}

Shu tarzda, bir xil kalitga ega bo'lgan barcha voqealar bir partiyada bo'lishi kafolatlanadi, bu tartibli ishlov berish va barqarorlik uchun muhimdir.