Release Notes

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'
9. [build] Run integration tests for each building
10. [changelog] fix changelog-deserialize exception message typo
11. [docs] Add FAQ for MySQL 8.0 Public Key Retrieval setting
12. [docs] Update the debezium document link to version 1.5
13. [docs] Add checkpoint and primary key setting for example in tutorials

Download

• flink-sql-connector-mysql-cdc-2.0.1.jar
• flink-sql-connector-postgres-cdc-2.0.1.jar
• flink-format-changelog-json-2.0.1.jar

Documentation

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