See tähendab, et tarne Kafka kaudu läbib kogu süsteemi ja Postgres'is ilmub 20?

Kui teil on Kafka-sõnumite voog ja olete seadistanud tarbija, mis loeb neid sõnumeid ja salvestab need Postgres andmebaasi, siis jah — sõnumid läbivad kogu süsteemi ja lõpuks võib neid Postgresis olla 20.

Oluline on mõista, et andmebaasis nähtavate sõnumite arv sõltub sellest, kui palju sõnumeid on Kafka-sse saadetud ja kuidas töötlemine on seadistatud. Näiteks, kui Kafka-sse saadeti 20 sõnumit ja tarbija töötles need õigesti, siis Postgresis ilmub 20 kirjet.

Näide Go keeles kasutades Sarama (Kafka klient) ja kirjutades Postgresi:

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

    for msg := range partitionConsumer.Messages() {
        // Sõnumi analüüs ja salvestamine Postgresi
        saveToPostgres(msg.Value)
    }
}

Seega, Kafka sõnumite voog läbib süsteemi ja salvestatakse Postgresisse.