search

apache / flink-cdc

Flink CDC is a streaming data integration tool
https://nightlies.apache.org/flink/flink-cdc-docs-stable
Apache License 2.0
5.67k stars 1.92k forks source link

[Feature] Support oceanbase cdc connector #668

Closed leonardBang closed 2 years ago

leonardBang commented 2 years ago

OceanBase Database[1] is a native distributed relational database, it's an open source project with many users especially in the financial industry. With the Oceanbase CDC connector, we can help users to integrate data easily.

[1] https://github.com/oceanbase

wuchong commented 2 years ago

We can consume oceanbase transaction log using https://github.com/oceanbase/oblogclient, there is also a pull request in Canal community to add support for oceanbase: https://github.com/alibaba/canal/pull/3867.

Supporting oceanbase-cdc connector can help users to do streaming ETL and build real-time materialize view on Oceanbase very easy using Flink SQL. I think we can cooperate on this with Oceanbase community.

whhe commented 2 years ago

Hello team, I am the maintainer of oblogclient and will have a try on this in next few days.

leonardBang commented 2 years ago

Hello team, I am the maintainer of oblogclient and will have a try on this in next few days.

Happy to hear that @whhe , assigned this ticket to you.