¿Cómo realizar el envío forzado de datos a una partición específica en el sistema de almacenamiento de datos?

En los sistemas de almacenamiento de datos que utilizan particionado (por ejemplo, Kafka, Cassandra), para enviar datos de manera forzada a una partición específica, es necesario indicar explícitamente la clave de partición o el número de partición al escribir.

En Go, esto generalmente se hace a través de la API del cliente, donde al publicar un mensaje o escribir datos, se puede establecer la clave o la partición:

// Ejemplo para Kafka usando sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "mi_tema",
    Partition: 2, // indicar explícitamente la partición
    Key:   sarama.StringEncoder("clave_de_particion"),
    Value: sarama.StringEncoder("datos"),
}

Si la API no permite especificar directamente el número de partición, se puede establecer una clave de partición que se hashéa y determina la partición.

Por lo tanto, para enviar datos de manera forzada a la partición deseada, es necesario usar las capacidades del cliente para indicar la clave o el número de partición al escribir.