Jak vynutit odeslání dat do určité části v systému ukládání dat?

V systémech ukládání dat, které používají partičování (například Kafka, Cassandra), je nutné při zápisu výslovně uvést klíč partičování nebo číslo partičky, pokud chceme data vynutit do určité části.

V jazyce Go se to obvykle provádí přes API klienta, kde při publikování zprávy nebo zápisu dat lze nastavit klíč nebo partičku:

// Příklad pro Kafka s použitím sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "můj_téma",
    Partition: 2, // výslovně uvádíme partičku
    Key:   sarama.StringEncoder("klíč_pro_partičování"),
    Value: sarama.StringEncoder("data"),
}

Pokud API neumožňuje přímo specifikovat číslo partičky, lze nastavit klíč, který se hash-uje a určuje partičku.

Tímto způsobem je možné vynutit odeslání dat do požadované partičky, pokud využijete možnosti klienta pro určení klíče nebo čísla partičky při zápisu.