Como realizar o envio forçado de dados para uma partição específica no sistema de armazenamento de dados?

Nos sistemas de armazenamento de dados que utilizam particionamento (por exemplo, Kafka, Cassandra), para enviar dados de forma forçada para uma partição específica, é necessário indicar explicitamente a chave de particionamento ou o número da partição ao gravar.

Em Go, isso geralmente é feito através da API do cliente, onde ao publicar uma mensagem ou gravar dados, pode-se definir a chave ou a partição:

// Exemplo para Kafka usando sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "meu_topico",
    Partition: 2, // indicar explicitamente a partição
    Key:   sarama.StringEncoder("chave_de_particionamento"),
    Value: sarama.StringEncoder("dados"),
}

Se a API não permitir especificar diretamente o número da partição, pode-se definir uma chave de particionamento que é hashada e determina a partição.

Assim, para forçar o envio de dados para a partição desejada, é necessário usar as capacidades do cliente para indicar a chave ou o número da partição ao gravar.