Как можно записывать данные из кафки в базу данных PostgreSQL?

Question

[Алекс Федоров]

Здравствуйте! На работе дали тестовое задание! Написать консьюмера для кафки и чтобы полученные данные из стрима записать в базу данных postgresql. Подскажите как можно это сделать ? какие библиотеки использовать

Answer 1

[Василий Банников]

Для работы с кафкой -
https://www.nuget.org/packages/Confluent.Kafka/1.9...

Для работы с постгресом -
https://www.nuget.org/packages/Npgsql/7.0.0-preview.4

Дальше по вкусу

Comments

[Алекс Федоров]

но для создания таблиц получается я должен знать содержимое key:value?

[Василий Банников]

Алекс Федоров, не понял, если честно, в чём проблема.
И key и value ты можешь достать из сообщения в кафке