Об этом проекте

Расширение **siddhi-io-cdc** — это расширение для Siddhi, которое захватывает данные об изменениях из таких баз данных, как MySQL, MS SQL, PostgreSQL, H2 и Oracle. Оно предоставляет источник `cdc`, который получает события в формате ключ-значение при срабатывании событий изменений (INSERT, UPDATE, DELETE) для таблицы базы данных. **Режимы:** - **Режим прослушивания:** Источник прослушивает журнал изменений базы данных и немедленно уведомляет об изменениях. Поддерживается для MySQL, PostgreSQL и SQL Server. Для Oracle требуется дополнительная настройка с использованием Oracle Instant Client. - **Режим опроса:** Источник данных периодически опрашивается на предмет изменений; можно захватывать только изменения INSERT и UPDATE. Требуется столбец опроса (автоинкремент или временная метка). **Конфигурация:** - Детали подключения (url, username, password, driverClassName) могут быть указаны в `deployment.yaml` в пространстве имен Siddhi. - Для режима прослушивания PostgreSQL настройте `slot.name` (по умолчанию: debezium), `plugin.name` (например, decoderbufs, pgoutput, wal2json) и `table.name` в формате `<схема>.<таблица>`. **Зависимости:** - В среду выполнения необходимо добавить jar-файл коннектора JDBC в зависимости от типа базы данных (см. документацию Debezium). - Для режима прослушивания требуется настройка конкретной базы данных (например, MySQL, PostgreSQL, SQL Server). **Установка:** - Следуйте документации Siddhi по добавлению расширений в различные среды выполнения. **Тестирование:** - Интеграционные тесты можно запускать в контейнерах Docker для H2, MySQL 5.7, PostgreSQL 9.6, MSSQL и Oracle 11.2.0.2-xe с использованием профилей Maven. **Поддержка:** - Вопросы можно задавать на StackOverflow с тегом `siddhi`; проблемы — на GitHub; информация о сообществе — на сайте Siddhi.