Kā nodrošināt, lai visi pasūtījuma notikumi nonāktu vienā Kafka daļā?

Lai nodrošinātu, ka visi notikumi par vienu pasūtījumu nonāk vienā Kafka daļā, ir jāizmanto atslēga (key) sūtīto ziņojumu nosūtīšanai, kas skaidri identificē pasūtījumu.

Kafka izmanto atslēgu, lai aprēķinātu daļu, izmantojot hash funkciju. Ja visiem vienas pasūtījuma notikumiem tiek izmantota tā pati atslēga (piemēram, order_id), tie nonāks tajā pašā daļā.

Piemērs Go valodā ar sarama (populārs Kafka klients):

producer.Input() <- &sarama.ProducerMessage{
    Topic: "orders",
    Key:   sarama.StringEncoder(orderID), // orderID — pasūtījuma identifikators
    Value: sarama.StringEncoder(eventData),
}

Tādējādi tiek garantēts, ka visi notikumi ar vienu un to pašu atslēgu būs tajā pašā daļā, kas ir svarīgi secīgas apstrādes un konsekvences nodrošināšanai.