apache/flink-cdc

📦 Pipeline Connectors Jars

• MySQL (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.6.0-2.2/flink-cdc-pipeline-connector-mysql-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.6.0-2.2/flink-cdc-pipeline-connector-mysql-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.6.0-2.2/flink-cdc-pipeline-connector-mysql-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.6.0-1.20/flink-cdc-pipeline-connector-mysql-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.6.0-1.20/flink-cdc-pipeline-connector-mysql-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.6.0-1.20/flink-cdc-pipeline-connector-mysql-3.6.0-1.20.jar.sha1))
• Doris (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.6.0-2.2/flink-cdc-pipeline-connector-doris-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.6.0-2.2/flink-cdc-pipeline-connector-doris-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.6.0-2.2/flink-cdc-pipeline-connector-doris-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.6.0-1.20/flink-cdc-pipeline-connector-doris-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.6.0-1.20/flink-cdc-pipeline-connector-doris-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.6.0-1.20/flink-cdc-pipeline-connector-doris-3.6.0-1.20.jar.sha1))
• Elasticsearch (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.6.0-2.2/flink-cdc-pipeline-connector-elasticsearch-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.6.0-2.2/flink-cdc-pipeline-connector-elasticsearch-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.6.0-2.2/flink-cdc-pipeline-connector-elasticsearch-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.6.0-1.20/flink-cdc-pipeline-connector-elasticsearch-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.6.0-1.20/flink-cdc-pipeline-connector-elasticsearch-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.6.0-1.20/flink-cdc-pipeline-connector-elasticsearch-3.6.0-1.20.jar.sha1))
• Fluss (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/3.6.0-2.2/flink-cdc-pipeline-connector-fluss-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/3.6.0-2.2/flink-cdc-pipeline-connector-fluss-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/3.6.0-2.2/flink-cdc-pipeline-connector-fluss-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/3.6.0-1.20/flink-cdc-pipeline-connector-fluss-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/3.6.0-1.20/flink-cdc-pipeline-connector-fluss-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-fluss/3.6.0-1.20/flink-cdc-pipeline-connector-fluss-3.6.0-1.20.jar.sha1))
• Hudi (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-hudi/3.6.0-2.2/flink-cdc-pipeline-connector-hudi-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-hudi/3.6.0-2.2/flink-cdc-pipeline-connector-hudi-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-hudi/3.6.0-2.2/flink-cdc-pipeline-connector-hudi-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-hudi/3.6.0-1.20/flink-cdc-pipeline-connector-hudi-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-hudi/3.6.0-1.20/flink-cdc-pipeline-connector-hudi-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-hudi/3.6.0-1.20/flink-cdc-pipeline-connector-hudi-3.6.0-1.20.jar.sha1))
• Iceberg (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-iceberg/3.6.0-2.2/flink-cdc-pipeline-connector-iceberg-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-iceberg/3.6.0-2.2/flink-cdc-pipeline-connector-iceberg-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-iceberg/3.6.0-2.2/flink-cdc-pipeline-connector-iceberg-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-iceberg/3.6.0-1.20/flink-cdc-pipeline-connector-iceberg-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-iceberg/3.6.0-1.20/flink-cdc-pipeline-connector-iceberg-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-iceberg/3.6.0-1.20/flink-cdc-pipeline-connector-iceberg-3.6.0-1.20.jar.sha1))
• Kafka (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.6.0-2.2/flink-cdc-pipeline-connector-kafka-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.6.0-2.2/flink-cdc-pipeline-connector-kafka-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.6.0-2.2/flink-cdc-pipeline-connector-kafka-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.6.0-1.20/flink-cdc-pipeline-connector-kafka-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.6.0-1.20/flink-cdc-pipeline-connector-kafka-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.6.0-1.20/flink-cdc-pipeline-connector-kafka-3.6.0-1.20.jar.sha1))
• MaxCompute (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.6.0-2.2/flink-cdc-pipeline-connector-maxcompute-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.6.0-2.2/flink-cdc-pipeline-connector-maxcompute-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.6.0-2.2/flink-cdc-pipeline-connector-maxcompute-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.6.0-1.20/flink-cdc-pipeline-connector-maxcompute-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.6.0-1.20/flink-cdc-pipeline-connector-maxcompute-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.6.0-1.20/flink-cdc-pipeline-connector-maxcompute-3.6.0-1.20.jar.sha1))
• + 5 more

📦 Source Connector Jars

• Db2 (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-db2-cdc/3.6.0-2.2/flink-connector-db2-cdc-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-db2-cdc/3.6.0-2.2/flink-connector-db2-cdc-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-db2-cdc/3.6.0-2.2/flink-connector-db2-cdc-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-db2-cdc/3.6.0-1.20/flink-connector-db2-cdc-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-db2-cdc/3.6.0-1.20/flink-connector-db2-cdc-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-db2-cdc/3.6.0-1.20/flink-connector-db2-cdc-3.6.0-1.20.jar.sha1))
• MongoDB (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mongodb-cdc/3.6.0-2.2/flink-connector-mongodb-cdc-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mongodb-cdc/3.6.0-2.2/flink-connector-mongodb-cdc-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mongodb-cdc/3.6.0-2.2/flink-connector-mongodb-cdc-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mongodb-cdc/3.6.0-1.20/flink-connector-mongodb-cdc-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mongodb-cdc/3.6.0-1.20/flink-connector-mongodb-cdc-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mongodb-cdc/3.6.0-1.20/flink-connector-mongodb-cdc-3.6.0-1.20.jar.sha1))
• MySQL (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mysql-cdc/3.6.0-2.2/flink-connector-mysql-cdc-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mysql-cdc/3.6.0-2.2/flink-connector-mysql-cdc-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mysql-cdc/3.6.0-2.2/flink-connector-mysql-cdc-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mysql-cdc/3.6.0-1.20/flink-connector-mysql-cdc-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mysql-cdc/3.6.0-1.20/flink-connector-mysql-cdc-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-mysql-cdc/3.6.0-1.20/flink-connector-mysql-cdc-3.6.0-1.20.jar.sha1))
• OceanBase (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oceanbase-cdc/3.6.0-2.2/flink-connector-oceanbase-cdc-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oceanbase-cdc/3.6.0-2.2/flink-connector-oceanbase-cdc-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oceanbase-cdc/3.6.0-2.2/flink-connector-oceanbase-cdc-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oceanbase-cdc/3.6.0-1.20/flink-connector-oceanbase-cdc-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oceanbase-cdc/3.6.0-1.20/flink-connector-oceanbase-cdc-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oceanbase-cdc/3.6.0-1.20/flink-connector-oceanbase-cdc-3.6.0-1.20.jar.sha1))
• Oracle (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oracle-cdc/3.6.0-2.2/flink-connector-oracle-cdc-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oracle-cdc/3.6.0-2.2/flink-connector-oracle-cdc-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oracle-cdc/3.6.0-2.2/flink-connector-oracle-cdc-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oracle-cdc/3.6.0-1.20/flink-connector-oracle-cdc-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oracle-cdc/3.6.0-1.20/flink-connector-oracle-cdc-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-oracle-cdc/3.6.0-1.20/flink-connector-oracle-cdc-3.6.0-1.20.jar.sha1))
• PostgreSQL (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-postgres-cdc/3.6.0-2.2/flink-connector-postgres-cdc-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-postgres-cdc/3.6.0-2.2/flink-connector-postgres-cdc-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-postgres-cdc/3.6.0-2.2/flink-connector-postgres-cdc-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-postgres-cdc/3.6.0-1.20/flink-connector-postgres-cdc-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-postgres-cdc/3.6.0-1.20/flink-connector-postgres-cdc-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-postgres-cdc/3.6.0-1.20/flink-connector-postgres-cdc-3.6.0-1.20.jar.sha1))
• Microsoft SQL Server (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-sqlserver-cdc/3.6.0-2.2/flink-connector-sqlserver-cdc-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-sqlserver-cdc/3.6.0-2.2/flink-connector-sqlserver-cdc-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-sqlserver-cdc/3.6.0-2.2/flink-connector-sqlserver-cdc-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-sqlserver-cdc/3.6.0-1.20/flink-connector-sqlserver-cdc-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-sqlserver-cdc/3.6.0-1.20/flink-connector-sqlserver-cdc-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-sqlserver-cdc/3.6.0-1.20/flink-connector-sqlserver-cdc-3.6.0-1.20.jar.sha1))
• TiDB (2.2: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-tidb-cdc/3.6.0-2.2/flink-connector-tidb-cdc-3.6.0-2.2.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-tidb-cdc/3.6.0-2.2/flink-connector-tidb-cdc-3.6.0-2.2.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-tidb-cdc/3.6.0-2.2/flink-connector-tidb-cdc-3.6.0-2.2.jar.sha1), 1.20: [jar](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-tidb-cdc/3.6.0-1.20/flink-connector-tidb-cdc-3.6.0-1.20.jar) [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-tidb-cdc/3.6.0-1.20/flink-connector-tidb-cdc-3.6.0-1.20.jar.asc) [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-tidb-cdc/3.6.0-1.20/flink-connector-tidb-cdc-3.6.0-1.20.jar.sha1))
• + 1 more

📦 DataStream

• We would like to express gratitude to all the contributors working on this release:

📦 Pipeline Connectors Jars

• MySQL Pipeline Connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.5.0/flink-cdc-pipeline-connector-mysql-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.5.0/flink-cdc-pipeline-connector-mysql-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.5.0/flink-cdc-pipeline-connector-mysql-3.5.0.jar.sha1))
• Doris Pipeline Connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.5.0/flink-cdc-pipeline-connector-doris-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.5.0/flink-cdc-pipeline-connector-doris-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.5.0/flink-cdc-pipeline-connector-doris-3.5.0.jar.sha1))
• StarRocks Pipeline Connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.5.0/flink-cdc-pipeline-connector-starrocks-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.5.0/flink-cdc-pipeline-connector-starrocks-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.5.0/flink-cdc-pipeline-connector-starrocks-3.5.0.jar.sha1))
• Kafka Pipeline Connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.5.0/flink-cdc-pipeline-connector-kafka-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.5.0/flink-cdc-pipeline-connector-kafka-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.5.0/flink-cdc-pipeline-connector-kafka-3.5.0.jar.sha1))
• Paimon Pipeline Connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.5.0/flink-cdc-pipeline-connector-paimon-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.5.0/flink-cdc-pipeline-connector-paimon-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.5.0/flink-cdc-pipeline-connector-paimon-3.5.0.jar.sha1))
• Elasticsearch Pipeline Connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.5.0/flink-cdc-pipeline-connector-elasticsearch-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.5.0/flink-cdc-pipeline-connector-elasticsearch-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.5.0/flink-cdc-pipeline-connector-elasticsearch-3.5.0.jar.sha1))
• OceanBase Pipeline Connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-oceanbase/3.5.0/flink-cdc-pipeline-connector-oceanbase-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-oceanbase/3.5.0/flink-cdc-pipeline-connector-oceanbase-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-oceanbase/3.5.0/flink-cdc-pipeline-connector-oceanbase-3.5.0.jar.sha1))
• MaxCompute Pipeline Connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.5.0/flink-cdc-pipeline-connector-maxcompute-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.5.0/flink-cdc-pipeline-connector-maxcompute-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.5.0/flink-cdc-pipeline-connector-maxcompute-3.5.0.jar.sha1))
• + 3 more

📦 Source Connector Jars

• Db2 Source connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.5.0/flink-sql-connector-db2-cdc-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.5.0/flink-sql-connector-db2-cdc-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.5.0/flink-sql-connector-db2-cdc-3.5.0.jar.sha1))
• MongoDB Source connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.5.0/flink-sql-connector-mongodb-cdc-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.5.0/flink-sql-connector-mongodb-cdc-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.5.0/flink-sql-connector-mongodb-cdc-3.5.0.jar.sha1))
• MySQL Source connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.5.0/flink-sql-connector-mysql-cdc-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.5.0/flink-sql-connector-mysql-cdc-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.5.0/flink-sql-connector-mysql-cdc-3.5.0.jar.sha1))
• OceanBase Source connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.5.0/flink-sql-connector-oceanbase-cdc-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.5.0/flink-sql-connector-oceanbase-cdc-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.5.0/flink-sql-connector-oceanbase-cdc-3.5.0.jar.sha1))
• Oracle Source connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.5.0/flink-sql-connector-oracle-cdc-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.5.0/flink-sql-connector-oracle-cdc-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.5.0/flink-sql-connector-oracle-cdc-3.5.0.jar.sha1))
• PostgreSQL Source connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.5.0/flink-sql-connector-postgres-cdc-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.5.0/flink-sql-connector-postgres-cdc-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.5.0/flink-sql-connector-postgres-cdc-3.5.0.jar.sha1))
• Microsoft SQL Server Source connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.5.0/flink-sql-connector-sqlserver-cdc-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.5.0/flink-sql-connector-sqlserver-cdc-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.5.0/flink-sql-connector-sqlserver-cdc-3.5.0.jar.sha1))
• TiDB Source connector 3.5.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.5.0/flink-sql-connector-tidb-cdc-3.5.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.5.0/flink-sql-connector-tidb-cdc-3.5.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.5.0/flink-sql-connector-tidb-cdc-3.5.0.jar.sha1))
• + 1 more

📦 Pipeline Connectors Jars

• MySQL Pipeline Connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.4.0/flink-cdc-pipeline-connector-mysql-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.4.0/flink-cdc-pipeline-connector-mysql-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.4.0/flink-cdc-pipeline-connector-mysql-3.4.0.jar.sha1))
• Doris Pipeline Connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.4.0/flink-cdc-pipeline-connector-doris-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.4.0/flink-cdc-pipeline-connector-doris-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.4.0/flink-cdc-pipeline-connector-doris-3.4.0.jar.sha1))
• StarRocks Pipeline Connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.4.0/flink-cdc-pipeline-connector-starrocks-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.4.0/flink-cdc-pipeline-connector-starrocks-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.4.0/flink-cdc-pipeline-connector-starrocks-3.4.0.jar.sha1))
• Kafka Pipeline Connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.4.0/flink-cdc-pipeline-connector-kafka-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.4.0/flink-cdc-pipeline-connector-kafka-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.4.0/flink-cdc-pipeline-connector-kafka-3.4.0.jar.sha1))
• Paimon Pipeline Connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.4.0/flink-cdc-pipeline-connector-paimon-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.4.0/flink-cdc-pipeline-connector-paimon-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.4.0/flink-cdc-pipeline-connector-paimon-3.4.0.jar.sha1))
• Elasticsearch Pipeline Connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.4.0/flink-cdc-pipeline-connector-elasticsearch-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.4.0/flink-cdc-pipeline-connector-elasticsearch-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.4.0/flink-cdc-pipeline-connector-elasticsearch-3.4.0.jar.sha1))
• OceanBase Pipeline Connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-oceanbase/3.4.0/flink-cdc-pipeline-connector-oceanbase-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-oceanbase/3.4.0/flink-cdc-pipeline-connector-oceanbase-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-oceanbase/3.4.0/flink-cdc-pipeline-connector-oceanbase-3.4.0.jar.sha1))
• MaxCompute Pipeline Connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.4.0/flink-cdc-pipeline-connector-maxcompute-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.4.0/flink-cdc-pipeline-connector-maxcompute-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.4.0/flink-cdc-pipeline-connector-maxcompute-3.4.0.jar.sha1))
• + 1 more

📦 Source Connector Jars

• Db2 source connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.4.0/flink-sql-connector-db2-cdc-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.4.0/flink-sql-connector-db2-cdc-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.4.0/flink-sql-connector-db2-cdc-3.4.0.jar.sha1))
• MongoDB source connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.4.0/flink-sql-connector-mongodb-cdc-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.4.0/flink-sql-connector-mongodb-cdc-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.4.0/flink-sql-connector-mongodb-cdc-3.4.0.jar.sha1))
• MySQL source connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.4.0/flink-sql-connector-mysql-cdc-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.4.0/flink-sql-connector-mysql-cdc-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.4.0/flink-sql-connector-mysql-cdc-3.4.0.jar.sha1))
• OceanBase source connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.4.0/flink-sql-connector-oceanbase-cdc-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.4.0/flink-sql-connector-oceanbase-cdc-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.4.0/flink-sql-connector-oceanbase-cdc-3.4.0.jar.sha1))
• Oracle source connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.4.0/flink-sql-connector-oracle-cdc-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.4.0/flink-sql-connector-oracle-cdc-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.4.0/flink-sql-connector-oracle-cdc-3.4.0.jar.sha1))
• Postgres source connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.4.0/flink-sql-connector-postgres-cdc-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.4.0/flink-sql-connector-postgres-cdc-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.4.0/flink-sql-connector-postgres-cdc-3.4.0.jar.sha1))
• Microsoft SQL Server source connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.4.0/flink-sql-connector-sqlserver-cdc-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.4.0/flink-sql-connector-sqlserver-cdc-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.4.0/flink-sql-connector-sqlserver-cdc-3.4.0.jar.sha1))
• TiDB source connector 3.4.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.4.0/flink-sql-connector-tidb-cdc-3.4.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.4.0/flink-sql-connector-tidb-cdc-3.4.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.4.0/flink-sql-connector-tidb-cdc-3.4.0.jar.sha1))
• + 1 more

📦 Pipeline Connectors Jars

• MySQL Pipeline Connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.3.0/flink-cdc-pipeline-connector-mysql-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.3.0/flink-cdc-pipeline-connector-mysql-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.3.0/flink-cdc-pipeline-connector-mysql-3.3.0.jar.sha1))
• Doris Pipeline Connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.3.0/flink-cdc-pipeline-connector-doris-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.3.0/flink-cdc-pipeline-connector-doris-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.3.0/flink-cdc-pipeline-connector-doris-3.3.0.jar.sha1))
• StarRocks Pipeline Connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.3.0/flink-cdc-pipeline-connector-starrocks-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.3.0/flink-cdc-pipeline-connector-starrocks-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.3.0/flink-cdc-pipeline-connector-starrocks-3.3.0.jar.sha1))
• Kafka Pipeline Connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.3.0/flink-cdc-pipeline-connector-kafka-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.3.0/flink-cdc-pipeline-connector-kafka-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.3.0/flink-cdc-pipeline-connector-kafka-3.3.0.jar.sha1))
• Paimon Pipeline Connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.3.0/flink-cdc-pipeline-connector-paimon-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.3.0/flink-cdc-pipeline-connector-paimon-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.3.0/flink-cdc-pipeline-connector-paimon-3.3.0.jar.sha1))
• Elasticsearch Pipeline Connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.3.0/flink-cdc-pipeline-connector-elasticsearch-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.3.0/flink-cdc-pipeline-connector-elasticsearch-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.3.0/flink-cdc-pipeline-connector-elasticsearch-3.3.0.jar.sha1))
• OceanBase Pipeline Connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-oceanbase/3.3.0/flink-cdc-pipeline-connector-oceanbase-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-oceanbase/3.3.0/flink-cdc-pipeline-connector-oceanbase-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-oceanbase/3.3.0/flink-cdc-pipeline-connector-oceanbase-3.3.0.jar.sha1))
• MaxCompute Pipeline Connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.3.0/flink-cdc-pipeline-connector-maxcompute-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.3.0/flink-cdc-pipeline-connector-maxcompute-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-maxcompute/3.3.0/flink-cdc-pipeline-connector-maxcompute-3.3.0.jar.sha1))

📦 Source Connector Jars

• Db2 source connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.3.0/flink-sql-connector-db2-cdc-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.3.0/flink-sql-connector-db2-cdc-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.3.0/flink-sql-connector-db2-cdc-3.3.0.jar.sha1))
• MongoDB source connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.3.0/flink-sql-connector-mongodb-cdc-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.3.0/flink-sql-connector-mongodb-cdc-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.3.0/flink-sql-connector-mongodb-cdc-3.3.0.jar.sha1))
• MySQL source connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.3.0/flink-sql-connector-mysql-cdc-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.3.0/flink-sql-connector-mysql-cdc-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.3.0/flink-sql-connector-mysql-cdc-3.3.0.jar.sha1))
• OceanBase source connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.3.0/flink-sql-connector-oceanbase-cdc-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.3.0/flink-sql-connector-oceanbase-cdc-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.3.0/flink-sql-connector-oceanbase-cdc-3.3.0.jar.sha1))
• Oracle source connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.3.0/flink-sql-connector-oracle-cdc-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.3.0/flink-sql-connector-oracle-cdc-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.3.0/flink-sql-connector-oracle-cdc-3.3.0.jar.sha1))
• Postgres source connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.3.0/flink-sql-connector-postgres-cdc-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.3.0/flink-sql-connector-postgres-cdc-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.3.0/flink-sql-connector-postgres-cdc-3.3.0.jar.sha1))
• Microsoft SQL Server source connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.3.0/flink-sql-connector-sqlserver-cdc-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.3.0/flink-sql-connector-sqlserver-cdc-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.3.0/flink-sql-connector-sqlserver-cdc-3.3.0.jar.sha1))
• TiDB source connector 3.3.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.3.0/flink-sql-connector-tidb-cdc-3.3.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.3.0/flink-sql-connector-tidb-cdc-3.3.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.3.0/flink-sql-connector-tidb-cdc-3.3.0.jar.sha1))
• + 1 more

📦 Pipeline Connectors Jars

• MySQL Pipeline Connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.2.1/flink-cdc-pipeline-connector-mysql-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.2.1/flink-cdc-pipeline-connector-mysql-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.2.1/flink-cdc-pipeline-connector-mysql-3.2.1.jar.sha1))
• Doris Pipeline Connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.2.1/flink-cdc-pipeline-connector-doris-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.2.1/flink-cdc-pipeline-connector-doris-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.2.1/flink-cdc-pipeline-connector-doris-3.2.1.jar.sha1))
• StarRocks Pipeline Connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.2.1/flink-cdc-pipeline-connector-starrocks-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.2.1/flink-cdc-pipeline-connector-starrocks-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.2.1/flink-cdc-pipeline-connector-starrocks-3.2.1.jar.sha1))
• Kafka Pipeline Connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.2.1/flink-cdc-pipeline-connector-kafka-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.2.1/flink-cdc-pipeline-connector-kafka-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.2.1/flink-cdc-pipeline-connector-kafka-3.2.1.jar.sha1))
• Paimon Pipeline Connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.2.1/flink-cdc-pipeline-connector-paimon-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.2.1/flink-cdc-pipeline-connector-paimon-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.2.1/flink-cdc-pipeline-connector-paimon-3.2.1.jar.sha1))
• Elasticsearch Pipeline Connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.2.1/flink-cdc-pipeline-connector-elasticsearch-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.2.1/flink-cdc-pipeline-connector-elasticsearch-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.2.1/flink-cdc-pipeline-connector-elasticsearch-3.2.1.jar.sha1))

📦 Source Connector Jars

• Db2 source connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.2.1/flink-sql-connector-db2-cdc-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.2.1/flink-sql-connector-db2-cdc-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.2.1/flink-sql-connector-db2-cdc-3.2.1.jar.sha1))
• MongoDB source connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.2.1/flink-sql-connector-mongodb-cdc-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.2.1/flink-sql-connector-mongodb-cdc-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.2.1/flink-sql-connector-mongodb-cdc-3.2.1.jar.sha1))
• MySQL source connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.2.1/flink-sql-connector-mysql-cdc-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.2.1/flink-sql-connector-mysql-cdc-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.2.1/flink-sql-connector-mysql-cdc-3.2.1.jar.sha1))
• OceanBase source connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.2.1/flink-sql-connector-oceanbase-cdc-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.2.1/flink-sql-connector-oceanbase-cdc-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.2.1/flink-sql-connector-oceanbase-cdc-3.2.1.jar.sha1))
• Oracle source connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.2.1/flink-sql-connector-oracle-cdc-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.2.1/flink-sql-connector-oracle-cdc-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.2.1/flink-sql-connector-oracle-cdc-3.2.1.jar.sha1))
• Postgres source connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.2.1/flink-sql-connector-postgres-cdc-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.2.1/flink-sql-connector-postgres-cdc-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.2.1/flink-sql-connector-postgres-cdc-3.2.1.jar.sha1))
• Microsoft SQL Server source connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.2.1/flink-sql-connector-sqlserver-cdc-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.2.1/flink-sql-connector-sqlserver-cdc-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.2.1/flink-sql-connector-sqlserver-cdc-3.2.1.jar.sha1))
• TiDB source connector 3.2.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.2.1/flink-sql-connector-tidb-cdc-3.2.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.2.1/flink-sql-connector-tidb-cdc-3.2.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.2.1/flink-sql-connector-tidb-cdc-3.2.1.jar.sha1))
• + 1 more

📦 Pipeline Connectors Jars

• MySQL Pipeline Connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.2.0/flink-cdc-pipeline-connector-mysql-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.2.0/flink-cdc-pipeline-connector-mysql-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.2.0/flink-cdc-pipeline-connector-mysql-3.2.0.jar.sha1))
• Doris Pipeline Connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.2.0/flink-cdc-pipeline-connector-doris-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.2.0/flink-cdc-pipeline-connector-doris-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.2.0/flink-cdc-pipeline-connector-doris-3.2.0.jar.sha1))
• StarRocks Pipeline Connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.2.0/flink-cdc-pipeline-connector-starrocks-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.2.0/flink-cdc-pipeline-connector-starrocks-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.2.0/flink-cdc-pipeline-connector-starrocks-3.2.0.jar.sha1))
• Kafka Pipeline Connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.2.0/flink-cdc-pipeline-connector-kafka-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.2.0/flink-cdc-pipeline-connector-kafka-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.2.0/flink-cdc-pipeline-connector-kafka-3.2.0.jar.sha1))
• Paimon Pipeline Connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.2.0/flink-cdc-pipeline-connector-paimon-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.2.0/flink-cdc-pipeline-connector-paimon-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.2.0/flink-cdc-pipeline-connector-paimon-3.2.0.jar.sha1))
• Elasticsearch Pipeline Connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.2.0/flink-cdc-pipeline-connector-elasticsearch-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.2.0/flink-cdc-pipeline-connector-elasticsearch-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-elasticsearch/3.2.0/flink-cdc-pipeline-connector-elasticsearch-3.2.0.jar.sha1))

📦 Source Connector Jars

• Db2 source connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.2.0/flink-sql-connector-db2-cdc-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.2.0/flink-sql-connector-db2-cdc-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.2.0/flink-sql-connector-db2-cdc-3.2.0.jar.sha1))
• MongoDB source connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.2.0/flink-sql-connector-mongodb-cdc-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.2.0/flink-sql-connector-mongodb-cdc-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.2.0/flink-sql-connector-mongodb-cdc-3.2.0.jar.sha1))
• MySQL source connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.2.0/flink-sql-connector-mysql-cdc-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.2.0/flink-sql-connector-mysql-cdc-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.2.0/flink-sql-connector-mysql-cdc-3.2.0.jar.sha1))
• OceanBase source connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.2.0/flink-sql-connector-oceanbase-cdc-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.2.0/flink-sql-connector-oceanbase-cdc-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.2.0/flink-sql-connector-oceanbase-cdc-3.2.0.jar.sha1))
• Oracle source connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.2.0/flink-sql-connector-oracle-cdc-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.2.0/flink-sql-connector-oracle-cdc-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.2.0/flink-sql-connector-oracle-cdc-3.2.0.jar.sha1))
• Postgres source connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.2.0/flink-sql-connector-postgres-cdc-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.2.0/flink-sql-connector-postgres-cdc-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.2.0/flink-sql-connector-postgres-cdc-3.2.0.jar.sha1))
• Microsoft SQL Server source connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.2.0/flink-sql-connector-sqlserver-cdc-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.2.0/flink-sql-connector-sqlserver-cdc-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.2.0/flink-sql-connector-sqlserver-cdc-3.2.0.jar.sha1))
• TiDB source connector 3.2.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.2.0/flink-sql-connector-tidb-cdc-3.2.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.2.0/flink-sql-connector-tidb-cdc-3.2.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.2.0/flink-sql-connector-tidb-cdc-3.2.0.jar.sha1))
• + 1 more

📦 Pipeline Connectors Jars

• MySQL Pipeline Connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.1.1/flink-cdc-pipeline-connector-mysql-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.1.1/flink-cdc-pipeline-connector-mysql-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.1.1/flink-cdc-pipeline-connector-mysql-3.1.1.jar.sha1))
• Doris Pipeline Connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.1.1/flink-cdc-pipeline-connector-doris-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.1.1/flink-cdc-pipeline-connector-doris-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.1.1/flink-cdc-pipeline-connector-doris-3.1.1.jar.sha1))
• StarRocks Pipeline Connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.1.1/flink-cdc-pipeline-connector-starrocks-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.1.1/flink-cdc-pipeline-connector-starrocks-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.1.1/flink-cdc-pipeline-connector-starrocks-3.1.1.jar.sha1))
• Kafka Pipeline Connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.1.1/flink-cdc-pipeline-connector-kafka-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.1.1/flink-cdc-pipeline-connector-kafka-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.1.1/flink-cdc-pipeline-connector-kafka-3.1.1.jar.sha1))
• Paimon Pipeline Connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.1.1/flink-cdc-pipeline-connector-paimon-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.1.1/flink-cdc-pipeline-connector-paimon-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.1.1/flink-cdc-pipeline-connector-paimon-3.1.1.jar.sha1))

📦 Source Connector Jars

• Db2 source connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.1.1/flink-sql-connector-db2-cdc-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.1.1/flink-sql-connector-db2-cdc-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.1.1/flink-sql-connector-db2-cdc-3.1.1.jar.sha1))
• MongoDB source connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.1.1/flink-sql-connector-mongodb-cdc-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.1.1/flink-sql-connector-mongodb-cdc-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.1.1/flink-sql-connector-mongodb-cdc-3.1.1.jar.sha1))
• MySQL source connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.1/flink-sql-connector-mysql-cdc-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.1/flink-sql-connector-mysql-cdc-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.1/flink-sql-connector-mysql-cdc-3.1.1.jar.sha1))
• OceanBase source connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.1.1/flink-sql-connector-oceanbase-cdc-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.1.1/flink-sql-connector-oceanbase-cdc-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.1.1/flink-sql-connector-oceanbase-cdc-3.1.1.jar.sha1))
• Oracle source connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.1.1/flink-sql-connector-oracle-cdc-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.1.1/flink-sql-connector-oracle-cdc-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.1.1/flink-sql-connector-oracle-cdc-3.1.1.jar.sha1))
• Postgres source connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.1.1/flink-sql-connector-postgres-cdc-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.1.1/flink-sql-connector-postgres-cdc-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.1.1/flink-sql-connector-postgres-cdc-3.1.1.jar.sha1))
• Microsoft SQL Server source connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.1.1/flink-sql-connector-sqlserver-cdc-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.1.1/flink-sql-connector-sqlserver-cdc-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.1.1/flink-sql-connector-sqlserver-cdc-3.1.1.jar.sha1))
• TiDB source connector 3.1.1 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.1.1/flink-sql-connector-tidb-cdc-3.1.1.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.1.1/flink-sql-connector-tidb-cdc-3.1.1.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.1.1/flink-sql-connector-tidb-cdc-3.1.1.jar.sha1))
• + 1 more

📦 Pipeline Connectors Jars

• MySQL Pipeline Connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.1.0/flink-cdc-pipeline-connector-mysql-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.1.0/flink-cdc-pipeline-connector-mysql-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-mysql/3.1.0/flink-cdc-pipeline-connector-mysql-3.1.0.jar.sha1))
• Doris Pipeline Connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.1.0/flink-cdc-pipeline-connector-doris-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.1.0/flink-cdc-pipeline-connector-doris-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-doris/3.1.0/flink-cdc-pipeline-connector-doris-3.1.0.jar.sha1))
• StarRocks Pipeline Connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.1.0/flink-cdc-pipeline-connector-starrocks-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.1.0/flink-cdc-pipeline-connector-starrocks-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-starrocks/3.1.0/flink-cdc-pipeline-connector-starrocks-3.1.0.jar.sha1))
• Kafka Pipeline Connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.1.0/flink-cdc-pipeline-connector-kafka-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.1.0/flink-cdc-pipeline-connector-kafka-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-kafka/3.1.0/flink-cdc-pipeline-connector-kafka-3.1.0.jar.sha1))
• Paimon Pipeline Connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.1.0/flink-cdc-pipeline-connector-paimon-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.1.0/flink-cdc-pipeline-connector-paimon-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-cdc-pipeline-connector-paimon/3.1.0/flink-cdc-pipeline-connector-paimon-3.1.0.jar.sha1))

📦 Source Connector Jars

• Db2 source connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.1.0/flink-sql-connector-db2-cdc-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.1.0/flink-sql-connector-db2-cdc-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-db2-cdc/3.1.0/flink-sql-connector-db2-cdc-3.1.0.jar.sha1))
• MongoDB source connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.1.0/flink-sql-connector-mongodb-cdc-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.1.0/flink-sql-connector-mongodb-cdc-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.1.0/flink-sql-connector-mongodb-cdc-3.1.0.jar.sha1))
• MySQL source connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.0/flink-sql-connector-mysql-cdc-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.0/flink-sql-connector-mysql-cdc-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.1.0/flink-sql-connector-mysql-cdc-3.1.0.jar.sha1))
• OceanBase source connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.1.0/flink-sql-connector-oceanbase-cdc-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.1.0/flink-sql-connector-oceanbase-cdc-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.1.0/flink-sql-connector-oceanbase-cdc-3.1.0.jar.sha1))
• Oracle source connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.1.0/flink-sql-connector-oracle-cdc-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.1.0/flink-sql-connector-oracle-cdc-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.1.0/flink-sql-connector-oracle-cdc-3.1.0.jar.sha1))
• Postgres source connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.1.0/flink-sql-connector-postgres-cdc-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.1.0/flink-sql-connector-postgres-cdc-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-postgres-cdc/3.1.0/flink-sql-connector-postgres-cdc-3.1.0.jar.sha1))
• Microsoft SQL Server source connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.1.0/flink-sql-connector-sqlserver-cdc-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.1.0/flink-sql-connector-sqlserver-cdc-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.1.0/flink-sql-connector-sqlserver-cdc-3.1.0.jar.sha1))
• TiDB source connector 3.1.0 ([jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.1.0/flink-sql-connector-tidb-cdc-3.1.0.jar), [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.1.0/flink-sql-connector-tidb-cdc-3.1.0.jar.asc), [sha1](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.1.0/flink-sql-connector-tidb-cdc-3.1.0.jar.sha1))
• + 1 more

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-3.0

📦 Flink CDC

• The binary release can be verified by public key with fingerprint `F8822354BF424A5CFF9AFD57BAF388953EF5327A`.

📦 Flink CDC Pipeline Connectors

• All connectors are release in JAR and available in Maven central repository.
• Apache Doris pipeline connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-doris/3.0.1/flink-cdc-pipeline-connector-doris-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-doris/3.0.1/flink-cdc-pipeline-connector-doris-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-doris/3.0.1/flink-cdc-pipeline-connector-doris-3.0.1.jar.sha1))
• MySQL pipeline connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-mysql/3.0.1/flink-cdc-pipeline-connector-mysql-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-mysql/3.0.1/flink-cdc-pipeline-connector-mysql-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-mysql/3.0.1/flink-cdc-pipeline-connector-mysql-3.0.1.jar.sha1))
• StarRocks pipeline connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-starrocks/3.0.1/flink-cdc-pipeline-connector-starrocks-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-starrocks/3.0.1/flink-cdc-pipeline-connector-starrocks-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-starrocks/3.0.1/flink-cdc-pipeline-connector-starrocks-3.0.1.jar.sha1))
• Values pipeline connector 3.0.1 (for testing purpose, [jar](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-values/3.0.1/flink-cdc-pipeline-connector-values-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-values/3.0.1/flink-cdc-pipeline-connector-values-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-values/3.0.1/flink-cdc-pipeline-connector-values-3.0.1.jar.sha1))

📦 Flink CDC Source Connectors

• All connectors are release in JAR and available in Maven central repository.
• Db2 source connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-db2-cdc/3.0.1/flink-sql-connector-db2-cdc-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-db2-cdc/3.0.1/flink-sql-connector-db2-cdc-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-db2-cdc/3.0.1/flink-sql-connector-db2-cdc-3.0.1.jar.sha1))
• MongoDB source connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/3.0.1/flink-sql-connector-mongodb-cdc-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/3.0.1/flink-sql-connector-mongodb-cdc-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/3.0.1/flink-sql-connector-mongodb-cdc-3.0.1.jar.sha1))
• MySQL source connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/3.0.1/flink-sql-connector-mysql-cdc-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/3.0.1/flink-sql-connector-mysql-cdc-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/3.0.1/flink-sql-connector-mysql-cdc-3.0.1.jar.sha1))
• OceanBase source connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oceanbase-cdc/3.0.1/flink-sql-connector-oceanbase-cdc-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oceanbase-cdc/3.0.1/flink-sql-connector-oceanbase-cdc-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oceanbase-cdc/3.0.1/flink-sql-connector-oceanbase-cdc-3.0.1.jar.sha1))
• Oracle source connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/3.0.1/flink-sql-connector-oracle-cdc-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/3.0.1/flink-sql-connector-oracle-cdc-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/3.0.1/flink-sql-connector-oracle-cdc-3.0.1.jar.sha1))
• Postgres source connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/3.0.1/flink-sql-connector-postgres-cdc-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/3.0.1/flink-sql-connector-postgres-cdc-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/3.0.1/flink-sql-connector-postgres-cdc-3.0.1.jar.sha1))
• Microsoft SQL Server source connector 3.0.1 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-sqlserver-cdc/3.0.1/flink-sql-connector-sqlserver-cdc-3.0.1.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-sqlserver-cdc/3.0.1/flink-sql-connector-sqlserver-cdc-3.0.1.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-sqlserver-cdc/3.0.1/flink-sql-connector-sqlserver-cdc-3.0.1.jar.sha1))
• + 2 more

🐛 Improvements and Bug fixes

• 1.[cdc-base][hotfix] Fix SourceSplitSerializer to get totalFinishedSplitSize from recovery in 4th version
• 2.[hotfix][cdc-common] Fix NoSuchMethodError of CollectionUtil.newHashMapWithExpectedSize
• 3.[cdc][e2e] Unify logic to clean docker image when connector e2e test finished (#2978)
• 4.[pipeline-connector][mysql] fix timestamp with timezone format (#2952)
• 5.[doc] fix invalid page in website and update yaml in tutorial.
• 6.[cdc-connector][oracledb] Fix oracle read exceed high_watermark in backfill phase
• 7.[pipeline-connector][starrocks] Optimize char type mapping for starrocks pipeline connector (#2895)
• 8.[pipeline-connector][doris][starrocks] Remove SimpleDateFormat for thread safe (#2954)
• + 15 more

📦 Contributor List (sorted alphabetically)

• 1. GOODBOY008
• 2. He Wang
• 3. Hongshun Wang
• 4. joyCurry30
• 5. Kunni
• 6. Shawn Huang
• 7. TorinJie
• 8. Xin Gong
• + 3 more

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-3.0

📦 Flink CDC

• The binary release can be verified by public key with fingerprint `C460A307EAF2701FC9D774EF96719B746D3D0C8A`.

📦 Flink CDC Pipeline Connectors

• All connectors are release in JAR and available in Maven central repository.
• Apache Doris pipeline connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-doris/3.0.0/flink-cdc-pipeline-connector-doris-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-doris/3.0.0/flink-cdc-pipeline-connector-doris-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-doris/3.0.0/flink-cdc-pipeline-connector-doris-3.0.0.jar.sha1))
• MySQL pipeline connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-mysql/3.0.0/flink-cdc-pipeline-connector-mysql-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-mysql/3.0.0/flink-cdc-pipeline-connector-mysql-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-mysql/3.0.0/flink-cdc-pipeline-connector-mysql-3.0.0.jar.sha1))
• Starrocks pipeline connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-starrocks/3.0.0/flink-cdc-pipeline-connector-starrocks-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-starrocks/3.0.0/flink-cdc-pipeline-connector-starrocks-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-starrocks/3.0.0/flink-cdc-pipeline-connector-starrocks-3.0.0.jar.sha1))
• Values pipeline connector 3.0.0 (for testing purpose, [jar](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-values/3.0.0/flink-cdc-pipeline-connector-values-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-values/3.0.0/flink-cdc-pipeline-connector-values-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-values/3.0.0/flink-cdc-pipeline-connector-values-3.0.0.jar.sha1))

📦 Flink CDC Source Connectors

• All connectors are release in JAR and available in Maven central repository.
• Db2 source connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-db2-cdc/3.0.0/flink-sql-connector-db2-cdc-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-db2-cdc/3.0.0/flink-sql-connector-db2-cdc-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-db2-cdc/3.0.0/flink-sql-connector-db2-cdc-3.0.0.jar.sha1))
• MongoDB source connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/3.0.0/flink-sql-connector-mongodb-cdc-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/3.0.0/flink-sql-connector-mongodb-cdc-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/3.0.0/flink-sql-connector-mongodb-cdc-3.0.0.jar.sha1))
• MySQL source connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/3.0.0/flink-sql-connector-mysql-cdc-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/3.0.0/flink-sql-connector-mysql-cdc-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/3.0.0/flink-sql-connector-mysql-cdc-3.0.0.jar.sha1))
• OceanBase source connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oceanbase-cdc/3.0.0/flink-sql-connector-oceanbase-cdc-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oceanbase-cdc/3.0.0/flink-sql-connector-oceanbase-cdc-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oceanbase-cdc/3.0.0/flink-sql-connector-oceanbase-cdc-3.0.0.jar.sha1))
• Oracle source connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/3.0.0/flink-sql-connector-oracle-cdc-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/3.0.0/flink-sql-connector-oracle-cdc-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/3.0.0/flink-sql-connector-oracle-cdc-3.0.0.jar.sha1))
• Postgres source connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/3.0.0/flink-sql-connector-postgres-cdc-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/3.0.0/flink-sql-connector-postgres-cdc-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/3.0.0/flink-sql-connector-postgres-cdc-3.0.0.jar.sha1))
• Microsoft SQL Server source connector 3.0.0 ([jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-sqlserver-cdc/3.0.0/flink-sql-connector-sqlserver-cdc-3.0.0.jar), [asc](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-sqlserver-cdc/3.0.0/flink-sql-connector-sqlserver-cdc-3.0.0.jar.asc), [sha1](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-sqlserver-cdc/3.0.0/flink-sql-connector-sqlserver-cdc-3.0.0.jar.sha1))
• + 2 more

✨ Features and Improvements

• 1. [pipeline-connector][starrocks] Fix char/varchar length inconsistency between cdc and starrocks (#2830)
• 2. [cdc-cli][cdc-composer] Use "source-table" and "sink-table" as keywords of route (#2825)
• 3. [build][hotfix] Remove duplicate dependency (#2826)
• 4. [cdc-cli][cdc-dist] Support loading global config from FLINK_CDC_HOME (#2822)
• 5. [cdc-common][hotfix] Remove redundant prefix of pipeline options (#2821)
• 6. [cdc-source-connector][oceanbase][e2e] Add OceanBase e2e test case (#2521)
• 7. [build] Use flink-shaded-force-shading to force all submodules to generate dependency-reduced-pom.xml
• 8. [build] Use ${project.version} instead of ${revision} for dependency version
• + 215 more

📦 Contributor List (sorted alphabetically)

• 1. BIN
• 2. Dian Qi
• 3. EchoLee5
• 4. FlechazoW
• 5. FocusComputing
• 6. Hang Ruan
• 7. He Wang
• 8. Hongshun Wang
• + 38 more

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.4

🐛 Improvements and Bug fixes

• 1. [sqlserver] Fix get latest lsn (#2551)
• 2. [sqlserver] Add support bigint type as table split column (#2416)
• 3. [hotfix] Fix vitess docker image tag
• 4. [e2e] Remove db docker image after test cases are executed. (#2508)
• 5. [postgres] Not drop replication slot for stream split (#2436)
• 6. [postgres] Close jdbc connection after creating replication slot for stream split (#2425)
• 7. [cdc-base] Fix TM hangs caused by uncaught exception (#2511)
• 8. [postgres] Close idle readers when snapshot finished (#2400)
• + 23 more

📦 Contributor List (sorted alphabetically)

• 1. BIN
• 2. FocusComputing
• 3. GOODBOY008
• 4. Hang Ruan
• 5. Hongshun Wang
• 6. Jiabao Sun
• 7. Kunni
• 8. Leonard Xu
• + 9 more

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.4

✨ Features and Improvements

• 1. [hotfix] Fix sqlserver monitor same table in other database (#2335)
• 2. [debezium] Fix DebeizumSourceFunction can not do savepoint after close (#2259)
• 3. [mysql] skip closing reader when the reader received the binlog split (#2261)
• 4. [MySQL] Optimize how to construct config table.include.list (#2274)
• 5. [oracle] Fix class conflict when using multi cdc sql connector
• 6. [MySQL] Fix the startup mode exception message (#2264)
• 7. [hotfix][mysql] remove unused code (#2231)
• 8. [mysql] Fix assigning duplicate snapshot splits when enable scan newly added tables (#2326)
• + 8 more

📦 Contributor List (sorted alphabetically)

• 1. Hang Ruan
• 2. Leonard Xu
• 3. SileiWu
• 4. empcl
• 5. gongzhongqiang
• 6. skylines
• 7. syyfffy

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.4

✨ Features and Improvements

• 1. [hotfix] Add vitess connector to the release profile
• 2. [docs][hotfix] Update debezium reference links to 1.9 version
• 3. [build] Update the copyright year to 2023 (#2205)
• 4. [postgres] Fix postgres e2e test
• 5. [postgres] scan.incremental.snapshot.enabled is closed by default
• 6. [postgres] Backfill task will be able to end when there is not new change data but read the ending lsn
• 7. [postgres] Create slot for backfill task before snapshot reading
• 8. [postgres] Prepare a slot for the unique global stream split
• + 78 more

📦 Contributor List (sorted alphabetically)

• 1. Hang Ruan
• 2. He Wang
• 3. JasonLee
• 4. Jiabao Sun
• 5. Jingsong Lee
• 6. Xiao Meng
• 7. Leonard Xu
• 8. Qingsheng Ren
• + 24 more

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.3

✨ Features and Improvements

• 1. [mysql] Improve error message under the case that start reading from earliest but schema change happened before (#1724)
• 2. [mysql] Use event filter to drop events earlier than the specified timestamp in timestamp startup mode (#1724)
• 3. [docs][oracle] Add new introduced config options from incremental snapshot framework (#1718)
• 4. [docs][oceanbase][zh] Update outdated sections and translate them to Chinese
• 5. [hotfix][docs] Add link for Oceanbase ZH docs
• 6. [docs][oceanbase] Add Chinese documents for oceanbase-cdc connector(#1611)
• 7. [db2] Fix stream api example in db2 doc. (#1725)
• 8. [oracle] Add missing supported config options for oracle table source (#1720)
• + 164 more

📦 Download

• [flink-sql-connector-db2-cdc-2.3.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-db2-cdc/2.3.0/flink-sql-connector-db2-cdc-2.3.0.jar)
• [flink-sql-connector-mongodb-cdc-2.3.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/2.3.0/flink-sql-connector-mongodb-cdc-2.3.0.jar)
• [flink-sql-connector-mysql-cdc-2.3.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.3.0/flink-sql-connector-mysql-cdc-2.3.0.jar)
• [flink-sql-connector-oceanbase-cdc-2.3.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oceanbase-cdc/2.3.0/flink-sql-connector-oceanbase-cdc-2.3.0.jar)
• [flink-sql-connector-oracle-cdc-2.3.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/2.3.0/flink-sql-connector-oracle-cdc-2.3.0.jar)
• [flink-sql-connector-postgres-cdc-2.3.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/2.3.0/flink-sql-connector-postgres-cdc-2.3.0.jar)
• [flink-sql-connector-sqlserver-cdc-2.3.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-sqlserver-cdc/2.3.0/flink-sql-connector-sqlserver-cdc-2.3.0.jar)
• [flink-sql-connector-tidb-cdc-2.3.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-tidb-cdc/2.3.0/flink-sql-connector-tidb-cdc-2.3.0.jar)

📦 Contributor List (sorted alphabetically)

• 1. 01410172
• 2. Amber Moe
• 3. Dezhi Cai
• 4. Enoch
• 5. Hang Ruan
• 6. He Wang
• 7. JiaJia
• 8. Jiabao Sun
• + 41 more

🐛 Improvements and Bug fixes

• 1. [docs] Update the dependencies version used in docs to 2.2.0
• 2. [hotfix][docs] Fix jar link for PolarDB-X docs (#1013)
• 3. [docs] Add example for Scan Newly Added tables feature (#1016)
• 4. [hotfix][docs] Fix misspell of docs title
• 5. [docs][mysql] Add note to make the tableList usage and dependencies clearer (#1037)
• 6. [docs] Update the supported sink vendors
• 7. [sqlserver] Add more supported(tested) SqlServer versions (#1049)
• 8. [oceanbase] Remove useless dependency and code of test (#1046)
• + 9 more

📦 Download

• [flink-sql-connector-mongodb-cdc-2.2.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/2.2.1/flink-sql-connector-mongodb-cdc-2.2.1.jar)
• [flink-sql-connector-mysql-cdc-2.2.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.2.1/flink-sql-connector-mysql-cdc-2.2.1.jar)
• [flink-sql-connector-oceanbase-cdc-2.2.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oceanbase-cdc/2.2.1/flink-sql-connector-oceanbase-cdc-2.2.1.jar)
• [flink-sql-connector-oracle-cdc-2.2.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/2.2.1/flink-sql-connector-oracle-cdc-2.2.1.jar)
• [flink-sql-connector-postgres-cdc-2.2.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/2.2.1/flink-sql-connector-postgres-cdc-2.2.1.jar)
• [flink-sql-connector-sqlserver-cdc-2.2.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-sqlserver-cdc/2.2.1/flink-sql-connector-sqlserver-cdc-2.2.1.jar)
• [flink-sql-connector-tidb-cdc-2.2.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-tidb-cdc/2.2.1/flink-sql-connector-tidb-cdc-2.2.1.jar)

📝 Documentation

• https://ververica.github.io/flink-cdc-connectors/release-2.2/

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.2/

✨ Features and Improvements

• 1. [docs] Update the supported database vendors and improve the notes.
• 2. [docs][mysql][polardbx] Add polardbx tutorials (#1003)
• 3. [docs][mysql] Remove redundant docker environment variable in tutorials (#1005)
• 4. [cdc-base] Add MySQL Incremental Source to validate the Incremental Snapshot Framework(#776)
• 5. [cdc-base] Improve the Incremental Snapshot Interfaces
• 6. [cdc-base] The first version of Incremental Snapshot Framework abstraction
• 7. [hotfix][docs] Fix markdown title due to typo in readme
• 8. [oceanbase] Bump the oblogclient version to 1.0.3 to fix the NPE in oblogclient connection (#998)
• + 101 more

📦 Download

• [flink-sql-connector-mongodb-cdc-2.2.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/2.2.0/flink-sql-connector-mongodb-cdc-2.2.0.jar)
• [flink-sql-connector-mysql-cdc-2.2.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.2.0/flink-sql-connector-mysql-cdc-2.2.0.jar)
• [flink-sql-connector-oceanbase-cdc-2.2.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oceanbase-cdc/2.2.0/flink-sql-connector-oceanbase-cdc-2.2.0.jar)
• [flink-sql-connector-oracle-cdc-2.2.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/2.2.0/flink-sql-connector-oracle-cdc-2.2.0.jar)
• [flink-sql-connector-postgres-cdc-2.2.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/2.2.0/flink-sql-connector-postgres-cdc-2.2.0.jar)
• [flink-sql-connector-sqlserver-cdc-2.2.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-sqlserver-cdc/2.2.0/flink-sql-connector-sqlserver-cdc-2.2.0.jar)
• [flink-sql-connector-tidb-cdc-2.2.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-tidb-cdc/2.2.0/flink-sql-connector-tidb-cdc-2.2.0.jar)

📦 Contributor List (sorted alphabetically)

• 1. Dian Qi
• 2. He Wang
• 3. Jark Wu
• 4. Jiabao Sun
• 5. Jingsong Lee
• 6. Junwang Zhao
• 7. Konstantin Knauf
• 8. Leonard Xu
• + 26 more

🐛 Improvements and Bug fixes

• 1. [docs] Remove the fixed version of website (#730)
• 2. [hotfix][mysql] Set minimum connection pool size to 1 (#692)
• 3. [build] Bump log4j2 version to 2.16.0 (#714) Note: This project only uses log4j2 in test code and won't be influenced by log4shell vulnerability
• 4. [build] Remove override definition of maven-surefire-plugin in connectors pom (#673)
• 5. [docs] Add FAQ for tableList option usage in DataStream API (#634)
• 6. [mongodb] Support to connect MongoDB without authentication (#642)
• 7. [hotfix] Fix the parameter typo in java doc (#651)
• 8. [mysql] Set default driver class name for PooledDataSource (#659) (#661)
• + 5 more

📦 Download

• [flink-sql-connector-mysql-cdc-2.1.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.1.1/flink-sql-connector-mysql-cdc-2.1.1.jar)
• [flink-sql-connector-postgres-cdc-2.1.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/2.1.1/flink-sql-connector-postgres-cdc-2.1.1.jar)
• [flink-sql-connector-oracle-cdc-2.1.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/2.1.1/flink-sql-connector-oracle-cdc-2.1.1.jar)
• [flink-sql-connector-mongodb-cdc-2.1.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/2.1.1/flink-sql-connector-mongodb-cdc-2.1.1.jar)
• [flink-format-changelog-json-2.1.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-format-changelog-json/2.1.1/flink-format-changelog-json-2.1.1.jar)

📝 Documentation

• https://ververica.github.io/flink-cdc-connectors/release-2.1/

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.1/

✨ Features and Improvements

• 1. [tests] Add end-to-end tests for cdc connector uber jars (#594)
• 2. [tests] Upgrade testcontainers dependency to 1.16.2 (#591)
• 3. [mysql] Reading a null column with default value defined should return null instead of default value (#555)
• 4. [mysql] Optimize the dynamic chunk size calculation for table with dense distribution (#599)
• 5. [mongodb] Fix MongoDBConnectorITCase is timeout on Azure (#600)
• 6. [hotfix][mysql] Fix number overflow in ObjectUtils.minus (#598)
• 7. [mongodb] Fix problem of cannot look up fields on non-struct type (#588)
• 8. [hotfix][mongodb] Fix NullPointException when heartbeat option is enabled (#586)
• + 101 more

📦 Download

• [flink-sql-connector-mysql-cdc-2.1.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.1.0/flink-sql-connector-mysql-cdc-2.1.0.jar)
• [flink-sql-connector-postgres-cdc-2.1.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/2.1.0/flink-sql-connector-postgres-cdc-2.1.0.jar)
• [flink-sql-connector-oracle-cdc-2.1.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-oracle-cdc/2.1.0/flink-sql-connector-oracle-cdc-2.1.0.jar)
• [flink-sql-connector-mongodb-cdc-2.1.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mongodb-cdc/2.1.0/flink-sql-connector-mongodb-cdc-2.1.0.jar)
• [flink-format-changelog-json-2.1.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-format-changelog-json/2.1.0/flink-format-changelog-json-2.1.0.jar)

🐛 Improvements and Bug fixes

• 1. [mysql] Fix the MySqlSnapshotSplitAssigner may assign duplicate splits
• 2. [mysql] Fix the restoration failure when checkpoint happened in one MySQL transaction
• 3. [mysql] Fix the ClassCastException in RecordUtils
• 4. [mysql] Optimization that skips the binlog read if the low watermark equals high watermark
• 5. [mysql] Support wide table with huge number of columns
• 6. [mysql] Use min/max of split key and row count to describe the distribution of table
• 7. [mysql] Add source metrics for MySqlParallelSource
• 8. [tests] Correct the argument order of assertArrayEqualInOrder/assertArrayEqualAnyOrder
• + 9 more

📦 Download

• [flink-sql-connector-mysql-cdc-2.0.2.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.0.2/flink-sql-connector-mysql-cdc-2.0.2.jar)
• [flink-sql-connector-postgres-cdc-2.0.2.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/2.0.2/flink-sql-connector-postgres-cdc-2.0.2.jar)
• [flink-format-changelog-json-2.0.2.jar](https://repo1.maven.org/maven2/com/ververica/flink-format-changelog-json/2.0.2/flink-format-changelog-json-2.0.2.jar)

📝 Documentation

• [https://ververica.github.io/flink-cdc-connectors](https://ververica.github.io/flink-cdc-connectors/release-2.0/)

🐛 Improvements and Bug

• 1. [postgres] Fix Validator didn't implement Serializable
• 2. [mysql] Correct the initial binlog offset for MySqlHybridSplitAssigner
• 3. [mysql] Optimize the checkpoint be optional under single parallelism
• 4. [postgres] Fix postgres-cdc connector cannot recognize the optional option 'slot.name'
• 5. [mysql] Improve the code format in SignalEventDispatcher
• 6. [mysql] Add default value for 'database.history.instance.name' in MySqlParallelSource
• 7. [mysql] Add tests to check mysql-cdc works well under various timezones
• 8. [common] Remove useless parameter 'converter.schemas.enable'
• + 5 more

📦 Download

• [flink-sql-connector-mysql-cdc-2.0.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.0.1/flink-sql-connector-mysql-cdc-2.0.1.jar)
• [flink-sql-connector-postgres-cdc-2.0.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/2.0.1/flink-sql-connector-postgres-cdc-2.0.1.jar)
• [flink-format-changelog-json-2.0.1.jar](https://repo1.maven.org/maven2/com/ververica/flink-format-changelog-json/2.0.1/flink-format-changelog-json-2.0.1.jar)

📝 Documentation

• [https://ververica.github.io/flink-cdc-connectors](https://ververica.github.io/flink-cdc-connectors/release-2.0/)

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.0/
• 1. [mysql] Support MySQL-CDC 2.0 which offers parallel reading, lock-free and checkpoint feature
• 2. [mysql] Enable single server id for MySqlParallelSource
• 3. [mysql] Keep the global order of between snapshot records and binlog records
• 4. [mysql] Support binlog reader merge optimization
• 5. [mysql] Support numeric type optimization for split boundary calculation
• 6. [mysql] Support table with combined primary key
• 7. [mysql] Support latest-offset mode for MySqlParallelSource
• + 15 more

📦 Download

• [flink-sql-connector-mysql-cdc-2.0.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.0.0/flink-sql-connector-mysql-cdc-2.0.0.jar)
• [flink-sql-connector-postgres-cdc-2.0.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-postgres-cdc/2.0.0/flink-sql-connector-postgres-cdc-2.0.0.jar)
• [flink-format-changelog-json-2.0.0.jar](https://repo1.maven.org/maven2/com/ververica/flink-format-changelog-json/2.0.0/flink-format-changelog-json-2.0.0.jar)

📦 Release Notes

• Documentation: https://ververica.github.io/flink-cdc-connectors/release-1.4/

✨ Features and Improvements

• 1. [debezium] Bump Flink version to 1.13.0

📦 Download

• [flink-sql-connector-mysql-cdc-1.4.0.jar](https://repo1.maven.org/maven2/com/alibaba/ververica/flink-sql-connector-mysql-cdc/1.4.0/flink-sql-connector-mysql-cdc-1.4.0.jar)
• [flink-sql-connector-postgres-cdc-1.4.0.jar](https://repo1.maven.org/maven2/com/alibaba/ververica/flink-sql-connector-postgres-cdc/1.4.0/flink-sql-connector-postgres-cdc-1.4.0.jar)
• [flink-format-changelog-json-1.4.0.jar](https://repo1.maven.org/maven2/com/alibaba/ververica/flink-format-changelog-json/1.4.0/flink-format-changelog-json-1.4.0.jar)

📦 Release Notes

• 1. [postgres] Flush LSN offset to PG even if no updates to the monitored tables to avoid infinite WAL segments (#111)
• 2. [mysql] Fix NPE when the application started for the first time and captured a empty table (#119)
• 3. [debezium] Add source metrics according to FLIP-33

📦 Download

• [flink-sql-connector-mysql-cdc-1.3.0.jar](https://repo1.maven.org/maven2/com/alibaba/ververica/flink-sql-connector-mysql-cdc/1.3.0/flink-sql-connector-mysql-cdc-1.3.0.jar)
• [flink-sql-connector-postgres-cdc-1.3.0.jar](https://repo1.maven.org/maven2/com/alibaba/ververica/flink-sql-connector-postgres-cdc/1.3.0/flink-sql-connector-postgres-cdc-1.3.0.jar)
• [flink-format-changelog-json-1.3.0.jar](https://repo1.maven.org/maven2/com/alibaba/ververica/flink-format-changelog-json/1.3.0/flink-format-changelog-json-1.3.0.jar)

📦 Release Notes

• 1. [common] DebeziumSourceFunction only stores monitored table DDLs which cause error in some situation
• 2. [common] offset state missing if no binlog fetched tile checkpoint after restore
• 3. [common] Bump up Flink version to 1.12.1
• 4. [mysql] Support read from specific MySQL Binlog position
• 5. [mysql] Support "initial", "earliest-offset", "latest-offset" startup mode options
• 6. [mysql] Support read binlog from specific timestamp
• 7. [common] Remove logging security properties
• 8. [common] Bump Debezium version to 1.4.1.Final
• + 2 more

📦 Download

• [flink-sql-connector-mysql-cdc-1.2.0.jar](https://repo1.maven.org/maven2/com/alibaba/ververica/flink-sql-connector-mysql-cdc/1.2.0/flink-sql-connector-mysql-cdc-1.2.0.jar)
• [flink-sql-connector-postgres-cdc-1.2.0.jar](https://repo1.maven.org/maven2/com/alibaba/ververica/flink-sql-connector-postgres-cdc/1.2.0/flink-sql-connector-postgres-cdc-1.2.0.jar)
• [flink-format-changelog-json-1.2.0.jar](https://repo1.maven.org/maven2/com/alibaba/ververica/flink-format-changelog-json/1.2.0/flink-format-changelog-json-1.2.0.jar)