Kaip priverstinai siųsti duomenis į tam tikrą skaidymą duomenų saugojimo sistemoje?

Duomenų saugojimo sistemose, kurios naudoja skirstymą (pavyzdžiui, Kafka, Cassandra), norint priverstinai siųsti duomenis į tam tikrą skirstymą, reikia aiškiai nurodyti skirstymo raktą arba skirstymo numerį rašymo metu.

Go kalboje tai dažniausiai daroma per kliento API, kur rašant pranešimą ar įrašant duomenis, galima nustatyti raktą arba skirstymą:

// Pavyzdys Kafka su sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "mano_tema",
    Partition: 2, // aiškiai nurodome skirstymą
    Key:   sarama.StringEncoder("skirstymo_raktas"),
    Value: sarama.StringEncoder("duomenys"),
}

Jei API neleidžia tiesiogiai nurodyti skirstymo numerio, galima nustatyti skirstymo raktą, kuris yra hash-intas ir nustato skirstymą.

Taigi, norint priverstinai siųsti duomenis į norimą skirstymą, reikia naudoti kliento galimybes nurodyti raktą arba skirstymo numerį rašymo metu.