FlinkX

基于flink的分布式数据同步工具

Github星跟蹤圖

FlinkX

License

English, 中文

Communication

  • We are recruiting Big data platform development engineers.If you want more information about the position, please add WeChat ID [ysqwhiletrue] or email your resume to sishu@dtstack.com.

  • We use DingTalk to communicate,You can search the group number [30537511] or scan the QR code below to join the communication group

Introduction

FlinkX is a data synchronization tool based on Flink. FlinkX can collect static data, such as MySQL, HDFS, etc, as well as real-time changing data, such as MySQL binlog, Kafka, etc. FlinkX currently includes the following features:

  • Most plugins support concurrent reading and writing of data, which can greatly improve the speed of reading and writing;

  • Some plug-ins support the function of failure recovery, which can restore tasks from the failed location and save running time; Failure Recovery

  • The Reader plugin for relational databases supports interval polling. It can continuously collect changing data; Interval Polling

  • Some databases support opening Kerberos security authentication; Kerberos

  • Limit the reading speed of Reader plugins and reduce the impact on business databases;

  • Save the dirty data when writing data;

  • Limit the maximum number of dirty data;

  • Multiple running modes: Local,Standalone,Yarn Session,Yarn Per;

The following databases are currently supported:, Database Type, Reader, Writer, :----------------------:, :--------------:, :-------------------------------:, :-------------------------------:, Batch Synchronization, MySQL, doc, doc, Oracle, doc, doc, SqlServer, doc, doc, PostgreSQL, doc, doc, DB2, doc, doc, GBase, doc, doc, ClickHouse, doc, doc, PolarDB, doc, doc, SAP Hana, doc, doc, Teradata, doc, doc, Phoenix, doc, doc, 达梦, doc, doc, Cassandra, doc, doc, ODPS, doc, doc, HBase, doc, doc, MongoDB, doc, doc, Kudu, doc, doc, ElasticSearch, doc, doc, FTP, doc, doc, HDFS, doc, doc, Carbondata, doc, doc, Stream, doc, doc, Redis, doc, Hive, doc, Stream Synchronization, Kafka, doc, doc, EMQX, doc, doc, MySQL Binlog, doc, MongoDB Oplog, doc, PostgreSQL WAL, doc, Oracle Logminer, Coming Soon, SqlServer CDC, Coming Soon, # Quick Start

Please click Quick Start

General Configuration

Please click General Configuration

Statistics Metric

Please click Statistics Metric

Kerberos

Please click Kerberos

How to contribute FlinkX

Please click Contribution

License

FlinkX is under the Apache 2.0 license. See the LICENSE file for details.

主要指標

概覽
名稱與所有者DTStack/flinkx
主編程語言
編程語言Java (語言數: 0)
平台
許可證
所有者活动
創建於2022-01-20 09:07:55
推送於2022-02-22 12:56:45
最后一次提交2022-02-22 20:56:45
發布數0
用户参与
星數49
關注者數13
派生數13
提交數3
已啟用問題?
問題數4
打開的問題數4
拉請求數0
打開的拉請求數0
關閉的拉請求數0
项目设置
已啟用Wiki?
已存檔?
是復刻?
已鎖定?
是鏡像?
是私有?