Wie führt man eine erzwungene Datenübertragung in eine bestimmte Partition im Datenspeichersystem durch?

In Datenspeichersystemen, die Partitionierung verwenden (z.B. Kafka, Cassandra), um Daten gezielt an eine bestimmte Partition zu senden, muss beim Schreiben explizit der Partitionierungsschlüssel oder die Partitionsnummer angegeben werden.

In Go erfolgt dies in der Regel über die API des Clients, bei der beim Veröffentlichen einer Nachricht oder beim Schreiben von Daten der Schlüssel oder die Partition festgelegt werden kann:

// Beispiel für Kafka mit sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "mein_thema",
    Partition: 2, // explizit die Partition angeben
    Key:   sarama.StringEncoder("partitionierungsschlüssel"),
    Value: sarama.StringEncoder("daten"),
}

Wenn die API die direkte Angabe der Partitionsnummer nicht zulässt, kann ein Partitionierungsschlüssel gesetzt werden, der gehasht wird und die Partition bestimmt.

Um Daten gezielt an eine bestimmte Partition zu senden, muss also die Client-API genutzt werden, um beim Schreiben den Schlüssel oder die Partitionsnummer anzugeben.