siddhi-io-cdc

La **extensión siddhi-io-cdc** es una extensión para Siddhi que captura datos de cambio de bases de datos como MySQL, MS SQL, PostgreSQL, H2 y Oracle. Proporciona una fuente `cdc` que recibe eventos cuando se activan eventos de cambio (INSERT, UPDATE, DELETE) en una tabla de base de datos, en formato clave-valor. **Modos:** - **Modo de escucha:** La fuente escucha el registro de cambios de la base de datos y notifica inmediatamente sobre los cambios. Compatible con MySQL, PostgreSQL y SQL Server. Para Oracle, se requiere configuración adicional con Oracle Instant Client. - **Modo de sondeo:** Se consulta periódicamente la fuente de datos para detectar cambios; solo se pueden capturar cambios INSERT y UPDATE. Requiere una columna de sondeo (autoincremental o marca de tiempo). **Configuración:** - Los detalles de conexión (url, username, password, driverClassName) se pueden proporcionar en `deployment.yaml` bajo el espacio de nombres de Siddhi. - Para el modo de escucha de PostgreSQL, configure `slot.name` (predeterminado: debezium), `plugin.name` (por ejemplo, decoderbufs, pgoutput, wal2json) y `table.name` como `<schema>.<table>`. **Dependencias:** - El jar del conector JDBC debe agregarse al entorno de ejecución según el tipo de base de datos (consulte la documentación de Debezium). - Se requiere configuración específica de la base de datos para el modo de escucha (por ejemplo, MySQL, PostgreSQL, SQL Server). **Instalación:** - Siga la documentación de Siddhi para agregar extensiones a varios entornos de ejecución. **Pruebas:** - Las pruebas de integración se pueden ejecutar en contenedores Docker para H2, MySQL 5.7, PostgreSQL 9.6, MSSQL y Oracle 11.2.0.2-xe utilizando perfiles de Maven. **Soporte:** - Preguntas vía StackOverflow con la etiqueta `siddhi`; problemas en GitHub; información comunitaria en el sitio web de Siddhi.