Tas nozīmē, ka piegāde caur Kafka iet cauri visai sistēmai un 20 parādās Postgres?

Ja jums ir ir plūsma ziņojumu Kafka un esat konfigurējis patērētāju, kas lasa šos ziņojumus un ieraksta tos Postgres datu bāzē, tad jā — ziņojumi pāriet caur visu sistēmu un galbūt 20 parādīsies Postgres.

Svarīgi saprast, ka skaits ziņojumu, kas parādās datu bāzē, ir atkarīgs no tā, cik ziņojumu tika nosūtīti uz Kafka un kā ir konfigurēta apstrāde. Piemēram, ja uz Kafka tika nosūtīti 20 ziņojumi un patērētājs tos pareizi apstrādāja, tad Postgres parādīs 20 ierakstus.

Piemērs Go valodā ar Sarama (Kafka klients) un ierakstu Postgres:

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

    for msg := range partitionConsumer.Messages() {
        // Analizēt ziņojumu un saglabāt to Postgres
        saveToPostgres(msg.Value)
    }
}

Tādējādi, Kafka ziņojumu plūsma pāriet caur sistēmu un tiek saglabāta Postgres.