siddhi-io-cdc

L'extension **siddhi-io-cdc** est une extension de Siddhi qui capture les données de changement à partir de bases de données telles que MySQL, MS SQL, PostgreSQL, H2 et Oracle. Elle fournit une source `cdc` qui reçoit des événements lorsque des événements de changement (INSERT, UPDATE, DELETE) sont déclenchés sur une table de base de données, sous forme de clé-valeur. **Modes :** - **Mode écoute :** la source écoute le journal de changements de la base de données et notifie immédiatement les changements. Pris en charge pour MySQL, PostgreSQL et SQL Server. Pour Oracle, une configuration supplémentaire avec Oracle Instant Client est requise. - **Mode interrogation :** la source de données est interrogée périodiquement pour détecter les changements ; seuls les changements INSERT et UPDATE peuvent être capturés. Requiert une colonne d'interrogation (auto-incrémentation ou horodatage). **Configuration :** - Les détails de connexion (url, username, password, driverClassName) peuvent être fournis dans `deployment.yaml` sous l'espace de noms Siddhi. - Pour le mode écoute PostgreSQL, configurer `slot.name` (par défaut : debezium), `plugin.name` (par exemple decoderbufs, pgoutput, wal2json) et `table.name` sous la forme `schema.table`. **Dépendances :** - Le fichier jar du connecteur JDBC doit être ajouté au runtime, selon le type de base de données (consulter la documentation Debezium). - Une configuration spécifique à la base de données est requise pour le mode écoute (par exemple MySQL, PostgreSQL, SQL Server). **Installation :** - Suivre la documentation Siddhi pour ajouter des extensions aux différents environnements d'exécution. **Tests :** - Les tests d'intégration peuvent être exécutés dans des conteneurs Docker pour H2, MySQL 5.7, PostgreSQL 9.6, MSSQL et Oracle 11.2.0.2-xe à l'aide de profils Maven. **Assistance :** - Questions via StackOverflow avec le tag `siddhi` ; problèmes sur GitHub ; informations communautaires sur le site web Siddhi.