Kako izvršiti prinudno slanje podataka u određenu particiju u sistemu za skladištenje podataka?

U sistemima za skladištenje podataka koji koriste particionisanje (npr. Kafka, Cassandra), da biste prinudno poslali podatke u određenu particiju, potrebno je eksplicitno navesti ključ particionisanja ili broj particije prilikom zapisivanja.

U Go, to se obično radi putem API-ja klijenta, gde prilikom objavljivanja poruke ili zapisivanja podataka možete postaviti ključ ili particiju:

// Primer za Kafka koristeći sarama
producer.Input() <- &sarama.ProducerMessage{
    Topic: "moja_tema",
    Partition: 2, // eksplicitno navodimo particiju
    Key:   sarama.StringEncoder("ključ_za_particionisanje"),
    Value: sarama.StringEncoder("podatak"),
}

Ako API ne dozvoljava direktno navođenje broja particije, može se postaviti ključ particionisanja koji se hash-uje i određuje particiju.

Na taj način, da biste prinudno poslali podatke u željenu particiju, morate koristiti mogućnosti klijenta za navođenje ključa ili broja particije prilikom zapisivanja.