support tidb cdc

sunxiaojian · Aug 16, 2024 · 3d798a8 · 3d798a8
1 parent 8c5ef2d
commit 3d798a8
Show file tree

Hide file tree

Showing 34 changed files with 3,102 additions and 380 deletions.
diff --git a/config/plugin_config b/config/plugin_config
@@ -28,6 +28,7 @@ connector-cdc-mongodb
 connector-cdc-sqlserver
 connector-cdc-postgres
 connector-cdc-oracle
+connector-cdc-tidb
 connector-clickhouse
 connector-datahub
 connector-dingtalk

diff --git a/plugin-mapping.properties b/plugin-mapping.properties
@@ -103,6 +103,7 @@ seatunnel.source.Maxcompute = connector-maxcompute
 seatunnel.sink.Maxcompute = connector-maxcompute
 seatunnel.source.MySQL-CDC = connector-cdc-mysql
 seatunnel.source.MongoDB-CDC = connector-cdc-mongodb
+seatunnel.source.TiDB-CDC = connector-cdc-tidb
 seatunnel.sink.S3Redshift = connector-s3-redshift
 seatunnel.source.Web3j = connector-web3j
 seatunnel.source.TDengine = connector-tdengine

diff --git a/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/pom.xml b/seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/pom.xml
@@ -65,7 +65,6 @@
             <groupId>org.tikv</groupId>
             <artifactId>tikv-client-java</artifactId>
         </dependency>
-
     </dependencies>
 
 </project>
diff --git a/.../src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBDialect.java b/.../src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBDialect.java
diff --git a/...java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBIncrementalSource.java b/...java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBIncrementalSource.java
diff --git a/...g/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBIncrementalSourceFactory.java b/...g/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/TiDBIncrementalSourceFactory.java