Sobes.tech
Назад к вопросам
Senior
5

То есть поставка через Kafka проходит через всю систему и 20 штук появляется в Postgres?

Компании, где спрашивали
МВидеоМВидео

Ответ от нейросети

sobes.tech AI

Если у вас есть поток сообщений в 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.