Kā veikt piespiedu datu sūtīšanu uz noteiktu daļu datu glabāšanas sistēmā?

Datu glabāšanas sistēmās, kas izmanto sadalījumu (piemēram, Kafka, Cassandra), lai piespiestu datus nosūtīt uz konkrētu sadalījumu, ir skaidri jānorāda sadalījuma atslēga vai sadalījuma numurs rakstīšanas laikā.

Go valodā tas parasti tiek darīts caur klienta API, kur rakstot ziņojumu vai ierakstot datus, var iestatīt atslēgu vai sadalījumu:

// Piemērs Kafka ar sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "mans_tēma",
    Partition: 2, // skaidri norādām sadalījumu
    Key:   sarama.StringEncoder("sadalījuma_atslēga"),
    Value: sarama.StringEncoder("dati"),
}

Ja API neļauj tieši norādīt sadalījuma numuru, var iestatīt sadalījuma atslēgu, kas tiek hash-ēta un nosaka sadalījumu.

Tādējādi, piespiedu kārtā sūtot datus uz vēlamo sadalījumu, ir jāizmanto klienta iespējas norādīt atslēgu vai sadalījuma numuru rakstīšanas laikā.