Как да принудите изпращането на данни към определена партиция в системата за съхранение на данни?

В системите за съхранение на данни, които използват партициониране (например Kafka, Cassandra), за да изпратите данни принудително към определена партиция, трябва ясно да посочите ключа за партициониране или номера на партицията при запис.

В Go това обикновено се прави чрез API на клиента, където при публикуване на съобщение или записване на данни, можете да зададете ключ или партиция:

// Пример за Kafka с използване на sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "моя_тема",
    Partition: 2, // ясно посочваме партицията
    Key:   sarama.StringEncoder("ключ_за_партициониране"),
    Value: sarama.StringEncoder("данни"),
}

Ако API не позволява директно да се посочи номерът на партицията, може да се зададе ключ за партициониране, който се хешира и определя партицията.

По този начин, за да изпратите данни принудително към желаната партиция, трябва да използвате възможностите на клиента за посочване на ключ или номер на партиция при запис.