flink-cdc
flink-cdc copied to clipboard
Flink CDC is a streaming data integration tool
Firstly, support oracle, postgres and sqlserver
修复oracle数据库表主键是NUMBER类型且不指定p,s长度时报校验异常:org.apache.flink.table.api.ValidationException: Decimal precision must be between 1 and 38 (both inclusive).
修复oracle数据库scan.incremental.snapshot.chunk.key-column设置不生效的问题
Modify the schema and table name snapshot data reading problem with the same name. For example: I want to get data from databaseName: test1 schemaName: dbo tableName: fl_test, but my...
DBZ-5589 Mysql connector can't handle the case sensitive of rename/change column statement The bug is only fixed in debezium2.0 version, and I have copied a copy of the solution.
Add a AbstractJdbcSourceChunkSplitter to handle common logic
This change is w.r.t to the corresponding changes done to mysql binlog connector and Debezium to support transaction payload events (generated when mysql server has binlog compression ON). Ticket in...