Comment effectuer une envoi forcé de données dans une partition spécifique du système de stockage de données?

Dans les systèmes de stockage de données utilisant le partitionnement (par exemple, Kafka, Cassandra), pour envoyer des données de force à une partition spécifique, il est nécessaire d’indiquer explicitement la clé de partition ou le numéro de partition lors de l’écriture.

En Go, cela se fait généralement via l’API du client, où lors de la publication d’un message ou de l’écriture de données, vous pouvez définir la clé ou la partition:

// Exemple pour Kafka avec sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "mon_sujet",
    Partition: 2, // indiquer explicitement la partition
    Key:   sarama.StringEncoder("clé_de_partition"),
    Value: sarama.StringEncoder("données"),
}

Si l’API ne permet pas de spécifier directement le numéro de partition, vous pouvez définir une clé de partition qui est hachée et détermine la partition.

Ainsi, pour forcer l’envoi de données à la partition souhaitée, il faut utiliser les capacités du client pour indiquer la clé ou le numéro de partition lors de l’écriture.