Come fare in modo che tutti gli eventi di un ordine vadano in una singola partizione Kafka?

Perché tutti gli eventi di un singolo ordine finiscano in una stessa partizione di Kafka, è necessario usare una chiave (key) durante l'invio dei messaggi, che identifichi in modo univoco l'ordine.

Kafka utilizza la chiave per calcolare la partizione tramite una funzione hash. Se si utilizza la stessa chiave (ad esempio, order_id) per tutti gli eventi di un ordine, questi finiranno nella stessa partizione.

Esempio in Go con sarama (client Kafka popolare):

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

In questo modo, si garantisce che tutti gli eventi con la stessa chiave siano in una stessa partizione, il che è importante per l'elaborazione ordinata e la coerenza.