This is an automated email from the ASF dual-hosted git repository.
dailai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 57f47c2064 [Improve][PostgreSQL CDC]-PostgresSourceOptions description
error (#7813)
57f47c2064 is described below
commit 57f47c2064473af310cc68eafed5fbbab1d03112
Author: Asura7969 <[email protected]>
AuthorDate: Fri Oct 11 16:11:20 2024 +0800
[Improve][PostgreSQL CDC]-PostgresSourceOptions description error (#7813)
Co-authored-by: SC7192 <[email protected]>
---
docs/en/connector-v2/source/PostgreSQL-CDC.md | 4 ++--
.../seatunnel/cdc/postgres/source/PostgresSourceOptions.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/docs/en/connector-v2/source/PostgreSQL-CDC.md
b/docs/en/connector-v2/source/PostgreSQL-CDC.md
index be87d03edd..8197a72b99 100644
--- a/docs/en/connector-v2/source/PostgreSQL-CDC.md
+++ b/docs/en/connector-v2/source/PostgreSQL-CDC.md
@@ -86,7 +86,7 @@ ALTER TABLE your_table_name REPLICA IDENTITY FULL;
## Source Options
-| Name | Type | Required |
Default |
Description
[...]
+| Name | Type | Required |
Default | Description
[...]
|------------------------------------------------|----------|----------|----------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
| base-url | String | Yes | -
| The URL of the JDBC connection. Refer to a case:
`jdbc:postgresql://localhost:5432/postgres_cdc?loggerLevel=OFF`.
[...]
| username | String | Yes | -
| Name of the database to use when connecting to the database server.
[...]
@@ -94,7 +94,7 @@ ALTER TABLE your_table_name REPLICA IDENTITY FULL;
| database-names | List | No | -
| Database name of the database to monitor.
[...]
| table-names | List | Yes | -
| Table name of the database to monitor. The table name needs to include the
database name, for example: `database_name.table_name`
[...]
| table-names-config | List | No | -
| Table config list. for example: [{"table":
"db1.schema1.table1","primaryKeys":["key1"]}]
[...]
-| startup.mode | Enum | No |
INITIAL | Optional startup mode for PostgreSQL CDC consumer, valid
enumerations are `initial`, `earliest`, `latest` and `specific`. <br/>
`initial`: Synchronize historical data at startup, and then synchronize
incremental data.<br/> `earliest`: Startup from the earliest offset
possible.<br/> `latest`: Startup from the latest offset.<br/> `specific`:
Startup from user-supplied specific offsets. [...]
+| startup.mode | Enum | No |
INITIAL | Optional startup mode for PostgreSQL CDC consumer, valid
enumerations are `initial`, `earliest` and `latest`. <br/> `initial`:
Synchronize historical data at startup, and then synchronize incremental
data.<br/> `earliest`: Startup from the earliest offset possible.<br/>
`latest`: Startup from the latest offset.
[...]
| snapshot.split.size | Integer | No | 8096
| The split size (number of rows) of table snapshot, captured tables are
split into multiple splits when read the snapshot of table.
[...]
| snapshot.fetch.size | Integer | No | 1024
| The maximum fetch size for per poll when read table snapshot.
[...]
| slot.name | String | No | -
| The name of the PostgreSQL logical decoding slot that was created for
streaming changes from a particular plug-in for a particular database/schema.
The server uses this slot to stream events to the connector that you are
configuring. Default is seatunnel.
[...]
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresSourceOptions.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresSourceOptions.java
index 1be2b9a960..91fda42d34 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresSourceOptions.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresSourceOptions.java
@@ -38,7 +38,7 @@ public class PostgresSourceOptions {
.defaultValue(StartupMode.INITIAL)
.withDescription(
"Optional startup mode for CDC source,
valid enumerations are "
- + "\"initial\", \"earliest\",
\"latest\", \"timestamp\"\n or \"specific\"");
+ + "\"initial\", \"earliest\",
\"latest\"");
public static final SingleChoiceOption<StopMode> STOP_MODE =
(SingleChoiceOption)
@@ -47,5 +47,5 @@ public class PostgresSourceOptions {
.defaultValue(StopMode.NEVER)
.withDescription(
"Optional stop mode for CDC source, valid
enumerations are "
- + "\"never\", \"latest\",
\"timestamp\"\n or \"specific\"");
+ + "\"never\"");
}
