How to perform forced data submission to a specific partition in a storage system?

In data storage systems that use partitioning (for example, Kafka, Cassandra), to force data to be sent to a specific partition, you need to explicitly specify the partition key or partition number when writing.

In Go, this is usually done through the client API, where when publishing a message or writing data, you can set the key or partition:

// Example for Kafka using sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "my_topic",
    Partition: 2, // explicitly specify the partition
    Key:   sarama.StringEncoder("partitioning_key"),
    Value: sarama.StringEncoder("data"),
}

If the API does not allow specifying the partition number directly, you can set a partitioning key, which is hashed to determine the partition.

Thus, to forcibly send data to a specific partition, you need to use the client's capabilities to specify the key or partition number when writing.