Skip to content

Commit d392f5c

Browse files
committed
Enhancement:Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service.
1 parent 13c2456 commit d392f5c

44 files changed

Lines changed: 4901 additions & 6807 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

docs/content.zh/docs/connectors/flink-sources/oceanbase-cdc.md

Lines changed: 726 additions & 698 deletions
Large diffs are not rendered by default.

docs/content/docs/connectors/flink-sources/oceanbase-cdc.md

Lines changed: 752 additions & 692 deletions
Large diffs are not rendered by default.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/pom.xml

Lines changed: 1 addition & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -36,30 +36,10 @@ limitations under the License.
3636

3737
<dependency>
3838
<groupId>org.apache.flink</groupId>
39-
<artifactId>flink-cdc-base</artifactId>
39+
<artifactId>flink-connector-mysql-cdc</artifactId>
4040
<version>${project.version}</version>
4141
</dependency>
4242

43-
<!-- Debezium dependencies -->
44-
<dependency>
45-
<groupId>org.apache.flink</groupId>
46-
<artifactId>flink-connector-debezium</artifactId>
47-
<version>${project.version}</version>
48-
<exclusions>
49-
<exclusion>
50-
<artifactId>kafka-log4j-appender</artifactId>
51-
<groupId>org.apache.kafka</groupId>
52-
</exclusion>
53-
</exclusions>
54-
</dependency>
55-
56-
<!-- OceanBase Log Client -->
57-
<dependency>
58-
<groupId>com.oceanbase</groupId>
59-
<artifactId>oblogclient-logproxy</artifactId>
60-
<version>${oblogclient.version}</version>
61-
</dependency>
62-
6343
<!-- The MySQL JDBC driver for reading snapshot-->
6444
<dependency>
6545
<groupId>mysql</groupId>

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java

Lines changed: 1580 additions & 0 deletions
Large diffs are not rendered by default.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseSource.java

Lines changed: 0 additions & 313 deletions
This file was deleted.

0 commit comments

Comments
 (0)