Hoe voer je een geforceerde verzending van gegevens uit naar een specifieke partitie in het gegevensopslagsysteem?

In datasystemen die gebruik maken van partitionering (bijvoorbeeld Kafka, Cassandra), moet je om gegevens geforceerd naar een specifieke partitie te sturen, expliciet de partitioneringssleutel of het partitie-nummer aangeven bij het schrijven.

In Go gebeurt dit meestal via de API van de client, waarbij je bij het publiceren van een bericht of het schrijven van gegevens de sleutel of de partitie kunt instellen:

// Voorbeeld voor Kafka met sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "mijn_topic",
    Partition: 2, // expliciet de partitie aangeven
    Key:   sarama.StringEncoder("partitioneringssleutel"),
    Value: sarama.StringEncoder("gegevens"),
}

Als de API niet toestaat om direct het partitie-nummer op te geven, kan een partitioneringssleutel worden ingesteld die wordt gehasht en de partitie bepaalt.

Dus, om gegevens geforceerd naar de gewenste partitie te sturen, moet je de mogelijkheden van de client gebruiken om de sleutel of het partitie-nummer aan te geven bij het schrijven.