Sobre o projeto
A **extensão siddhi-io-cdc** é uma extensão do Siddhi que captura dados de alteração de bancos de dados como MySQL, MS SQL, PostgreSQL, H2 e Oracle. Ela fornece uma fonte `cdc` que recebe eventos quando eventos de alteração (INSERT, UPDATE, DELETE) são acionados para uma tabela de banco de dados, em formato chave-valor.
**Modos:**
- **Modo de escuta:** A fonte escuta o log de alterações do banco de dados e notifica imediatamente sobre alterações. Suportado para MySQL, PostgreSQL e SQL Server. Para Oracle, é necessária configuração adicional com o Oracle Instant Client.
- **Modo de polling:** A fonte de dados é consultada periodicamente em busca de alterações; apenas alterações INSERT e UPDATE podem ser capturadas. Requer uma coluna de polling (auto-incremento ou timestamp).
**Configuração:**
- Detalhes de conexão (url, username, password, driverClassName) podem ser fornecidos em `deployment.yaml` sob o namespace do Siddhi.
- Para o modo de escuta do PostgreSQL, configure `slot.name` (padrão: debezium), `plugin.name` (por exemplo, decoderbufs, pgoutput, wal2json) e `table.name` como `<schema>.<table>`.
**Dependências:**
- O jar do conector JDBC deve ser adicionado ao runtime, com base no tipo de banco de dados (consulte a documentação do Debezium).
- É necessária configuração específica do banco de dados para o modo de escuta (por exemplo, MySQL, PostgreSQL, SQL Server).
**Instalação:**
- Siga a documentação do Siddhi para adicionar extensões a vários ambientes de execução.
**Testes:**
- Testes de integração podem ser executados em contêineres Docker para H2, MySQL 5.7, PostgreSQL 9.6, MSSQL e Oracle 11.2.0.2-xe usando perfis Maven.
**Suporte:**
- Perguntas via StackOverflow com a tag `siddhi`; problemas no GitHub; informações da comunidade no site do Siddhi.
Comments
0 Rating appears after 10 ratings
Sign in to join the discussion.