Tehát a szállítás Kafka-n keresztül végigmegy az egész rendszeren, és 20 jelenik meg a Postgres-ban?

Ha van Kafka-ban üzenetfolyamod, és beállítottál egy fogyasztót, amely olvassa ezeket az üzeneteket, és beírja őket egy Postgres adatbázisba, akkor igen — az üzenetek átmennek az egész rendszeren, és végül 20 megjelenhet a Postgresban.

Fontos megérteni, hogy a megjelenő üzenetek száma attól függ, hány üzenetet küldtek Kafka-ba, és hogyan van beállítva a feldolgozás. Például, ha 20 üzenetet küldtek Kafka-ba, és a fogyasztó helyesen dolgozta fel őket, akkor 20 rekord jelenik meg a Postgresban.

Példa Go nyelven Sarama (Kafka kliens) és írás Postgresba:

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

    for msg := range partitionConsumer.Messages() {
        // Üzenet elemzése és mentése Postgresba
        saveToPostgres(msg.Value)
    }
}

Így a Kafka üzenetfolyam átmegy a rendszeren, és elmentésre kerül a Postgresban.