Демек, Kafka аркылуу жеткирүү бүт систем аркылуу өтүп, Postgres-та 20 пайда болот?

Эгерде сизде Kafkaда билдирүү агымы бар болсо жана сиз ушул билдирүүлөрдү окуган жана аларды Postgres базасына жазган керектөөчүнү конфигурациялаган болсоңуз, анда — билдирүүлөр бүт систем аркылуу өтөт жана акырында 20сы Postgresте пайда болушу мүмкүн.

Маанилүү, базада пайда болгон билдирүүлөрдүн саны Kafkaга жөнөтүлгөн билдирүүлөрдүн санына жана иштетүүнүн конфигурациясына көз каранды экенин түшүнүү. Мисалы, эгер Kafkaга 20 билдирүү жөнөтүлүп, керектөөчү аларды туура иштетсе, анда Postgresте 20 жазуу пайда болот.

Go тилинде Sarama (Kafka кардар) жана Postgresке жазуу мисалы:

// Псевдокод
func consumeAndSave() {
    consumer, _ := sarama.NewConsumer(brokers, config)
    partitionConsumer, _ := consumer.ConsumePartition(topic, 0, sarama.OffsetNewest)

    for msg := range partitionConsumer.Messages() {
        // Билдирүүнү талдап, Postgresке сактоо
        saveToPostgres(msg.Value)
    }
}

Мындайча айтканда, Kafkaдан келген билдирүү агымы систем аркылуу өтүп, Postgresке сакталат.