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
9. [postgres] Support 'slot.name' option for postgres-cdc connector
10. [postgres] Flush LSN offset to PG after checkpoint complete to avoid infinite WAL segments

Download

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