Яъне, расонидани тавассути Kafka дар тамоми систем мегузарад ва 20 дар Postgres пайдо мешавад?

Агар шумо дар Kafka ҷараёни паёмҳо дошта бошед ва як истеъмолкунандаро танзим карда бошед, ки ин паёмҳоро мехонад ва онҳоро ба базаи додаҳои Postgres сабт мекунад, пас — паёмҳо аз тамоми систем мегузаранд ва дар ниҳоят метавонанд 20 дар Postgres пайдо шаванд.

Муҳим аст, ки фаҳмед, ки шумораи паёмҳо, ки дар база пайдо мешаванд, аз он вобаста аст, ки чанд паём ба Kafka фиристода шудааст ва чӣ гуна коркард танзим шудааст. Масалан, агар 20 паём ба Kafka фиристода шуда бошад ва истеъмолкунанда онҳоро дуруст коркард кардааст, пас 20 сабт дар Postgres пайдо мешавад.

Маслиҳат дар Go бо истифода аз Sarama (мизоҷи Kafka) ва навишт ба Postgres:

// Псеудокод
func consumeAndSave() {
    consumer, _ := sarama.NewConsumer(brokers, config)
    partitionConsumer, _ := consumer.ConsumePartition(topic, 0, sarama.OffsetNewest)

    for msg := range partitionConsumer.Messages() {
        // Таҳлил кардани паём ва сабт дар Postgres
        saveToPostgres(msg.Value)
    }
}

Бинобар ин, ҷараёни паёмҳо аз Kafka мегузарад ва дар Postgres сабт мешавад.