Veri depolama sisteminde belirli bir bölüme zorunlu veri gönderimi nasıl yapılır?

Veri depolama sistemlerinde, bölümlendirme kullanan (örneğin Kafka, Cassandra) sistemlerde, verileri zorla belirli bir bölüme göndermek için, yazarken bölümlendirme anahtarını veya bölüm numarasını açıkça belirtmek gerekir.

Go'da bu genellikle müşteri API'si aracılığıyla yapılır; burada mesaj yayınlarken veya veri kaydederken anahtar veya bölüm belirlenebilir:

// Sarama kullanarak Kafka örneği
producer.Input() <- &sarama.ProducerMessage{
    Topic: "benim_konum",
    Partition: 2, // bölümü açıkça belirt
    Key:   sarama.StringEncoder("bölüm_anahtarı"),
    Value: sarama.StringEncoder("veri"),
}

Eğer API doğrudan bölüm numarasını belirtmeye izin vermiyorsa, hashlenmiş ve bölümü belirleyen bir bölümlendirme anahtarı ayarlanabilir.

Bu nedenle, verileri istenilen bölüme zorla göndermek için, yazarken anahtar veya bölüm numarasını belirlemek için müşteri API'sinin imkanları kullanılmalıdır.