Come eseguire l'invio forzato di dati in una partizione specifica nel sistema di archiviazione dei dati?

Nei sistemi di archiviazione dati che utilizzano il partizionamento (ad esempio Kafka, Cassandra), per inviare dati in modo forzato a una partizione specifica, è necessario indicare esplicitamente la chiave di partizionamento o il numero di partizione durante la scrittura.

In Go, questo di solito avviene tramite l'API del client, dove durante la pubblicazione di un messaggio o la scrittura di dati, è possibile impostare la chiave o la partizione:

// Esempio per Kafka con sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "mio_tema",
    Partition: 2, // indicare esplicitamente la partizione
    Key:   sarama.StringEncoder("chiave_di_partizionamento"),
    Value: sarama.StringEncoder("dati"),
}

Se l'API non permette di specificare direttamente il numero di partizione, si può impostare una chiave di partizionamento che viene hashata e determina la partizione.

Pertanto, per inviare dati in modo forzato alla partizione desiderata, è necessario utilizzare le capacità del client per indicare la chiave o il numero di partizione durante la scrittura.