Пример использования Debezium с Postgres и NATS JetStream без использования фреймворка Apache Kafka Connect.
В данном примере используется Debezium для отслеживания изменений в базе данных Postgres и отправки их в NATS JetStream.
Проект включает: • Debezium для отслеживания изменений в Postgres. • NATS JetStream для обработки и доставки событий. • Настройка Debezium-коннектора для Postgres с базовой трансформацией данных. Конфигурация находится в файле application.properties. • Скрипт и API для создания тестовых данных.
Для запуска используйте Docker Compose. Выполните команду:
docker-compose up -d --buildДля остановки и удаления контейнеров с их данными выполните:
docker-compose down -vДля создания начальной схемы и данных используется SQL-скрипт init.sql. Скрипт автоматически выполняется при первом запуске контейнера Postgres.
Для создания дополнительных тестовых данных в таблице public.products можно воспользоваться REST-методом. Выполните запрос:
curl -X POST http://localhost:8081/products