Назад к вопросам
МВидео
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.