From 08e9c756e1c0f432c9a032919939e33d9ab09aff Mon Sep 17 00:00:00 2001 From: gongzhongqiang <764629910@qq.com> Date: Wed, 18 Aug 2021 20:03:23 +0800 Subject: [PATCH] [docs] Update the debezium document link to version 1.5 --- docs/content/connectors/mysql-cdc.md | 6 +++--- docs/content/connectors/postgres-cdc.md | 6 +++--- .../com/ververica/cdc/debezium/DebeziumSourceFunction.java | 2 +- .../com/ververica/cdc/connectors/mysql/MySqlSource.java | 2 +- .../connectors/postgres/table/PostgresValueValidator.java | 2 +- 5 files changed, 9 insertions(+), 9 deletions(-) diff --git a/docs/content/connectors/mysql-cdc.md b/docs/content/connectors/mysql-cdc.md index 31379f0c0..2e45af246 100644 --- a/docs/content/connectors/mysql-cdc.md +++ b/docs/content/connectors/mysql-cdc.md @@ -45,7 +45,7 @@ mysql> GRANT SELECT, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *. mysql> FLUSH PRIVILEGES; ``` -See more about the [permission explanation](https://debezium.io/documentation/reference/1.2/connectors/mysql.html#_permissions_explained). +See more about the [permission explanation](https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-creating-user). Notes @@ -217,7 +217,7 @@ Connector Options String The session time zone in database server, e.g. "Asia/Shanghai". It controls how the TIMESTAMP type in MYSQL converted to STRING. - See more here. + See more here. debezium.min.row. @@ -242,7 +242,7 @@ During a snapshot operation, the connector will query each included table to pro String Pass-through Debezium's properties to Debezium Embedded Engine which is used to capture data changes from MySQL server. For example: 'debezium.snapshot.mode' = 'never'. - See more about the Debezium's MySQL Connector properties + See more about the Debezium's MySQL Connector properties diff --git a/docs/content/connectors/postgres-cdc.md b/docs/content/connectors/postgres-cdc.md index 100f74bc9..b2d002640 100644 --- a/docs/content/connectors/postgres-cdc.md +++ b/docs/content/connectors/postgres-cdc.md @@ -144,20 +144,20 @@ Connector Options String Pass-through Debezium's properties to Debezium Embedded Engine which is used to capture data changes from Postgres server. For example: 'debezium.snapshot.mode' = 'never'. - See more about the Debezium's Postgres Connector properties + See more about the Debezium's Postgres Connector properties -Note: `slot.name` is recommended to set for different tables to avoid the potential `PSQLException: ERROR: replication slot "flink" is active for PID 974` error. See more [here](https://debezium.io/documentation/reference/1.2/connectors/postgresql.html#postgresql-property-slot-name). +Note: `slot.name` is recommended to set for different tables to avoid the potential `PSQLException: ERROR: replication slot "flink" is active for PID 974` error. See more [here](https://debezium.io/documentation/reference/1.5/connectors/postgresql.html#postgresql-property-slot-name). Features -------- ### Exactly-Once Processing -The Postgres CDC connector is a Flink Source connector which will read database snapshot first and then continues to read binlogs with **exactly-once processing** even failures happen. Please read [How the connector works](https://debezium.io/documentation/reference/1.2/connectors/postgresql.html#how-the-postgresql-connector-works). +The Postgres CDC connector is a Flink Source connector which will read database snapshot first and then continues to read binlogs with **exactly-once processing** even failures happen. Please read [How the connector works](https://debezium.io/documentation/reference/1.5/connectors/postgresql.html#how-the-postgresql-connector-works). ### Single Thread Reading diff --git a/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/DebeziumSourceFunction.java b/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/DebeziumSourceFunction.java index bef852b96..c307ff598 100644 --- a/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/DebeziumSourceFunction.java +++ b/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/DebeziumSourceFunction.java @@ -101,7 +101,7 @@ import static com.ververica.cdc.debezium.utils.DatabaseHistoryUtil.retrieveHisto *

Note: currently, the source function can't run in multiple parallel instances. * *

Please refer to Debezium's documentation for the available configuration properties: - * https://debezium.io/documentation/reference/1.2/development/engine.html#engine-properties + * https://debezium.io/documentation/reference/1.5/development/engine.html#engine-properties */ @PublicEvolving public class DebeziumSourceFunction extends RichSourceFunction diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlSource.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlSource.java index 6dc2a8e58..3a609ebd6 100644 --- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlSource.java +++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlSource.java @@ -102,7 +102,7 @@ public class MySqlSource { /** * The session time zone in database server, e.g. "America/Los_Angeles". It controls how the * TIMESTAMP type in MYSQL converted to STRING. See more - * https://debezium.io/documentation/reference/1.2/connectors/mysql.html#_temporal_values + * https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-temporal-types */ public Builder serverTimeZone(String timeZone) { this.serverTimeZone = timeZone; diff --git a/flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/table/PostgresValueValidator.java b/flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/table/PostgresValueValidator.java index 4f95cfd99..c7566cfb0 100644 --- a/flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/table/PostgresValueValidator.java +++ b/flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/table/PostgresValueValidator.java @@ -32,7 +32,7 @@ public final class PostgresValueValidator "The \"before\" field of UPDATE/DELETE message is null, " + "please check the Postgres table has been set REPLICA IDENTITY to FULL level. " + "You can update the setting by running the command in Postgres 'ALTER TABLE %s REPLICA IDENTITY FULL'. " - + "Please see more in Debezium documentation: https://debezium.io/documentation/reference/1.2/connectors/postgresql.html#postgresql-replica-identity"; + + "Please see more in Debezium documentation: https://debezium.io/documentation/reference/1.5/connectors/postgresql.html#postgresql-replica-identity"; private final String schemaTable;