English | 简体中文
This repository contains the OceanBase connectors for Apache Flink.
Prerequisites
- JDK 8
- Flink 1.15 or later version
This repository contains connectors as following:
| Connector | Description | Document |
|---|---|---|
| Flink Connector: OceanBase | This Connector uses the JDBC driver supported by OceanBase to write data to OceanBase, and supports MySQL and Oracle compatibility modes. | Sink |
| Flink Connector: OceanBase Direct Load | This Connector uses the direct load API to write data to OceanBase. | Sink |
| Flink Connector: OBKV HBase | This Connector uses the OBKV HBase API to write data to OceanBase. | Sink |
There are some community projects which can be used to work with Apache Flink and OceanBase.
| Project | OceanBase Compatible Mode | Supported Features |
|---|---|---|
| Flink Connector JDBC | MySQL, Oracle | Source + Sink |
| Flink CDC | MySQL, Oracle | Source + CDC |
| Apache SeaTunnel | MySQL, Oracle | Source Sink |
Don’t hesitate to ask!
Contact the developers and community at https://ask.oceanbase.com if you need any help.
Open an issue if you found a bug.
See LICENSE for more information.