Hogyan hajtható végre az adatok kényszerített küldése egy adott partícióba az adattároló rendszerben?

Az adatszolgáltató rendszerekben, amelyek partícionálást használnak (pl. Kafka, Cassandra), az adatok kényszerített küldéséhez egy adott partícióba, világosan meg kell adni a partíció kulcsát vagy a partíció számát íráskor.

Go-ban ez általában az ügyfél API-n keresztül történik, ahol a üzenet közzététele vagy adatok írása során beállítható a kulcs vagy a partíció:

// Példa Kafka esetén sarama használatával
producer.Input() <- &sarama.ProducerMessage{
    Topic: "témám",
    Partition: 2, // világosan megadjuk a partíciót
    Key:   sarama.StringEncoder("partíció_kulcs"),
    Value: sarama.StringEncoder("adatok"),
}

Ha az API nem teszi lehetővé a partíció számának közvetlen megadását, akkor egy hash-elt partíció kulcsot lehet beállítani, amely meghatározza a partíciót.

Így, hogy kényszerítve küldjön adatokat a kívánt partícióba, a kliens lehetőségeit kell használni, azaz a kulcs vagy a partíció számának megadását íráskor.