მაშინ, Kafka-ის საშუალებით მიწოდება მთელი სისტემის გავლით გადის და 20-ი გამოჩნდება Postgres-ში?

თუ თქვენს კაფკაში შეტყობინებების ნაკადი გაქვთ და კონფიგურაცია გაქვთ, რომელიც ამ შეტყობინებებს კითხულობს და მათ პოსტგრეს ბაზაში წერს, მაშინ კი — შეტყობინებები მთელი სისტემის გავლით გადიან და საბოლოოდ 20 შეიძლება გამოჩნდეს პოსტგრესში.

მნიშვნელოვანია להבין, რომ ბაზაში გამოჩენილი შეტყობინებების რაოდენობა დამოკიდებულია იმაზე, რამდენი შეტყობინება გაიგზავნა კაფკაში და როგორ არის კონფიგურირებული დამუშავება. მაგალითად, თუ კაფკაში გაიგზავნა 20 შეტყობინება და მომხმარებელმა სწორად გამოავლინა, მაშინ 20 ჩანაწერი გამოჩნდება პოსტგრესში.

მაგალითი Go-ში, გამოყენებით Sarama (კაფკის კლიენტი) და პოსტგრესში ჩაწერა:

// ფსევდო-კოდი
func consumeAndSave() {
    consumer, _ := sarama.NewConsumer(brokers, config)
    partitionConsumer, _ := consumer.ConsumePartition(topic, 0, sarama.OffsetNewest)

    for msg := range partitionConsumer.Messages() {
        // შეტყობინების ანალიზი და შენახვა პოსტგრესში
        saveToPostgres(msg.Value)
    }
}

ამ გზით, კაფკიდან შეტყობინებების ნაკადი გადის სისტემას და ინახება პოსტგრესში.