Jak wymusić wysyłanie danych do określonej partycji w systemie przechowywania danych?

W systemach przechowywania danych korzystających z partycjonowania (np. Kafka, Cassandra), aby wymusić wysłanie danych do określonej partycji, należy wyraźnie wskazać klucz partycjonowania lub numer partycji podczas zapisu.

W Go zazwyczaj odbywa się to przez API klienta, gdzie podczas publikowania wiadomości lub zapisywania danych można ustawić klucz lub partycję:

// Przykład dla Kafka z użyciem sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "mój_temat",
    Partition: 2, // wyraźnie wskazujemy partycję
    Key:   sarama.StringEncoder("klucz_partycjonowania"),
    Value: sarama.StringEncoder("dane"),
}

Jeśli API nie pozwala na bezpośrednie wskazanie numeru partycji, można ustawić klucz partycjonowania, który jest haszowany i określa partycję.

W ten sposób, aby wymusić wysłanie danych do wybranej partycji, należy korzystać z możliwości klienta, wskazując klucz lub numer partycji podczas zapisu.