add kingbase cdc connector

baisui1981 · baisui1981 · commit 735094415d6a · 2025-01-23T13:00:42.000+08:00
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-kingbase-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-kingbase-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java
@@ -426,6 +426,11 @@ public void initConnection() throws SQLException, InterruptedException {
         }
     }
 
+    /**
+     * baisui note
+     * @return
+     * @throws SQLException
+     */
     @Override
     public Optional<SlotCreationResult> createReplicationSlot() throws SQLException {
         // note that some of these options are only supported in Postgres 9.4+, additionally
diff --git a/install.sh b/install.sh
@@ -1,3 +1,3 @@
 #添加
 
-mvn deploy -Dmaven.test.skip=true -Dfast -pl flink-cdc-connect/flink-cdc-source-connectors/flink-connector-kingbase-cdc -Ptis
+mvn deploy -Dmaven.test.skip=true -Dfast -pl flink-cdc-connect/flink-cdc-source-connectors/flink-connector-kingbase-cdc

Original file line number	Diff line number	Diff line change
`@@ -426,6 +426,11 @@ public void initConnection() throws SQLException, InterruptedException {`
`426`	`426`	`}`
`427`	`427`	`}`
`428`	`428`
	`429`	`+ /**`
	`430`	`+ * baisui note`
	`431`	`+ * @return`
	`432`	`+ * @throws SQLException`
	`433`	`+ */`
`429`	`434`	`@Override`
`430`	`435`	`public Optional<SlotCreationResult> createReplicationSlot() throws SQLException {`
`431`	`436`	`// note that some of these options are only supported in Postgres 9.4+, additionally`
Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,3 @@`
`1`	`1`	`#添加`
`2`	`2`
`3`		`-mvn deploy -Dmaven.test.skip=true -Dfast -pl flink-cdc-connect/flink-cdc-source-connectors/flink-connector-kingbase-cdc -Ptis`
	`3`	`+mvn deploy -Dmaven.test.skip=true -Dfast -pl flink-cdc-connect/flink-cdc-source-connectors/flink-connector-kingbase-cdc`