Маалыматтарды сактоо системасында белгилүү бир бөлүмгө мажбурлап жөнөтүүнү кантип ишке ашыруу керек?

Маалымат сактоо системдеринде, алар бөлүмгө бөлүү (мисалы, Kafka, Cassandra) колдонуп жатса, маалыматтарды мажбурлап белгилүү бир бөлүмгө жөнөтүү үчүн жазууда бөлүмдүн ачкычын же бөлүм номурун так көрсөтүү керек.

Goда бул адатта кардар API аркылуу ишке ашырылат, анда билдирүүнү жарыялоо же маалыматтарды жазууда ачкыч же бөлүмдү белгилөө мүмкүн:

// Sarama менен Kafka үчүн мисал
producer.Input() <- &sarama.ProducerMessage{
    Topic: "менин_тема",
    Partition: 2, // так бөлүмдү көрсөтөбүз
    Key:   sarama.StringEncoder("бөлүм_ачкычы"),
    Value: sarama.StringEncoder("маалымат"),
}

Эгер API түздөн-түз бөлүм номурун көрсөтүүгө мүмкүнчүлүк бербесе, хештелген жана бөлүмдү аныктаган бөлүм ачкычын коюу мүмкүн.

Ошентип, маалыматтарды зарыл болгон бөлүмгө мажбурлап жөнөтүү үчүн, жазууда кардар API мүмкүнчүлүктөрүн колдонуу керек, яғни ачкычты же бөлүм номурун көрсөтүү.