Yəni, Kafka vasitəsilə çatdırılma bütün sistemdən keçir və Postgres-də 20 çıxır?

Əgər Kafka-da mesaj axını varsa və bu mesajları oxuyan və onları Postgres bazasına yazan bir istehlakçı qurmusunuzsa, bəli — mesajlar bütün sistemdən keçir və nəticədə 20-si Postgres-də görünə bilər.

Əhəmiyyətlidir ki, bazada görünən mesajların sayı Kafka-ya göndərilən mesajların sayına və emalın necə qurulduğuna bağlıdır. Məsələn, Kafka-ya 20 mesaj göndərilibsə və istehlakçı onları düzgün işləyibsə, Postgres-də 20 qeyd görünəcək.

Go dilində Sarama (Kafka müştərisi) və Postgres-ə yazma nümunəsi:

// Pseudo-kod
func consumeAndSave() {
    consumer, _ := sarama.NewConsumer(brokers, config)
    partitionConsumer, _ := consumer.ConsumePartition(topic, 0, sarama.OffsetNewest)

    for msg := range partitionConsumer.Messages() {
        // Mesajı təhlil et və Postgres-ə qeyd et
        saveToPostgres(msg.Value)
    }
}

Beləliklə, Kafka-dan mesaj axını sistemdən keçir və Postgres-də saxlanılır.