flink-connector-debezium:此项目主要应用于数据中台或数据平台的数据总线，支持直接实时监听MySQL、MongoDB、PostgreSQL、Oracle、SQL Server、Db2和Cassandra等数据库的数据变更-源码

[{"title":"（ 14 个子文件 20KB ） flink-connector-debezium:此项目主要应用于数据中台或数据平台的数据总线，支持直接实时监听MySQL、MongoDB、PostgreSQL、Oracle、SQL Server、Db2和Cassandra等数据库的数据变更-源码","children":[{"title":"flink-connector-debezium-master","children":[{"title":".gitignore <span style='color:#111;'> 300B </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 1.20KB </span>","children":null,"spread":false},{"title":"logback.xml <span style='color:#111;'> 492B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"io","children":[{"title":"yanwu","children":[{"title":"flink","children":[{"title":"connector","children":[{"title":"debezium","children":[{"title":"ChangeRecord.java <span style='color:#111;'> 2.53KB </span>","children":null,"spread":false},{"title":"FlinkDatabaseHistory.java <span style='color:#111;'> 1.40KB </span>","children":null,"spread":false},{"title":"FlinkOffsetBackingStore.java <span style='color:#111;'> 1.14KB </span>","children":null,"spread":false},{"title":"DebeziumSource.java <span style='color:#111;'> 5.42KB </span>","children":null,"spread":false},{"title":"DebeziumOffset.java <span style='color:#111;'> 877B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 1.20KB </span>","children":null,"spread":false},{"title":"logback.xml <span style='color:#111;'> 492B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"io","children":[{"title":"yanwu","children":[{"title":"flink","children":[{"title":"connector","children":[{"title":"debezium","children":[{"title":"DebeziumSourceITCase.java <span style='color:#111;'> 2.99KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"LICENSE <span style='color:#111;'> 11.09KB </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 7.20KB </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 603B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]