This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch release-3.5
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/release-3.5 by this push:
new 29b64dde7 [minor][hotfix][docs] Fix some error in postgres yaml
document. (#4140) (#4143)
29b64dde7 is described below
commit 29b64dde7e18be778ba49c159774fb769ff16963
Author: Hongshun Wang <[email protected]>
AuthorDate: Wed Sep 24 15:42:28 2025 +0800
[minor][hotfix][docs] Fix some error in postgres yaml document. (#4140)
(#4143)
(cherry picked from commit ab70a2903d18777dff458aa6949d47116d652d8c)
---
.../connectors/pipeline-connectors/postgres.md | 25 ++++++++++++--------
.../connectors/pipeline-connectors/postgres.md | 27 +++++++++++++---------
2 files changed, 31 insertions(+), 21 deletions(-)
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/postgres.md
b/docs/content.zh/docs/connectors/pipeline-connectors/postgres.md
index aa8ce7793..50206761a 100644
--- a/docs/content.zh/docs/connectors/pipeline-connectors/postgres.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/postgres.md
@@ -31,7 +31,7 @@ Postgres CDC Pipeline 连接器允许从 Postgres 数据库读取快照数据和
## 示例
-从 Postgres 读取数据同步到 Doris 的 Pipeline 可以定义如下：
+从 Postgres 读取数据同步到 Fluss 的 Pipeline 可以定义如下：
```yaml
source:
@@ -41,19 +41,23 @@ source:
port: 5432
username: admin
password: pass
- tables: adb.\.*.\.*, bdb.user_schema_[0-9].user_table_[0-9]+,
[app|web].schema_\.*.order_\.*
+ # 需要确保所有的表来自同一个database
+ tables: adb.\.*.\.*
decoding.plugin.name: pgoutput
slot.name: pgtest
sink:
- type: doris
- name: Doris Sink
- fenodes: 127.0.0.1:8030
- username: root
- password: pass
+ type: fluss
+ name: Fluss Sink
+ bootstrap.servers: localhost:9123
+ # Security-related properties for the Fluss client
+ properties.client.security.protocol: sasl
+ properties.client.security.sasl.mechanism: PLAIN
+ properties.client.security.sasl.username: developer
+ properties.client.security.sasl.password: developer-pass
pipeline:
- name: Postgres to Doris Pipeline
+ name: Postgres to Fluss Pipeline
parallelism: 4
```
@@ -105,8 +109,9 @@ pipeline:
<td style="word-wrap: break-word;">(none)</td>
<td>String</td>
<td>需要监视的 Postgres 数据库的表名。表名支持正则表达式，以监视满足正则表达式的多个表。<br>
- 需要注意的是，点号（.）被视为数据库和表名的分隔符。
如果需要在正则表达式中使用点（.）来匹配任何字符，必须使用反斜杠对点进行转义。<br>
- 例如，adb.\.*.\.*, bdb.user_schema_[0-9].user_table_[0-9]+,
[app|web].schema_\.*.order_\.*</td>
+ 需要确保所有的表来自同一个数据库。<br>
+ 需要注意的是，点号（.）被视为数据库、模式和表名的分隔符。
如果需要在正则表达式中使用点（.）来匹配任何字符，必须使用反斜杠对点进行转义。<br>
+ 例如，bdb.user_schema_[0-9].user_table_[0-9]+,
bdb.schema_\.*.order_\.*</td>
</tr>
<tr>
<td>slot.name</td>
diff --git a/docs/content/docs/connectors/pipeline-connectors/postgres.md
b/docs/content/docs/connectors/pipeline-connectors/postgres.md
index 1a51486f0..03dd4e5a3 100644
--- a/docs/content/docs/connectors/pipeline-connectors/postgres.md
+++ b/docs/content/docs/connectors/pipeline-connectors/postgres.md
@@ -32,29 +32,33 @@ Note: Since the Postgres WAL log cannot parse table
structure change records, Po
## Example
-An example of the pipeline for reading data from Postgres and sink to Doris
can be defined as follows:
+An example of the pipeline for reading data from Postgres and sink to Fluss
can be defined as follows:
```yaml
source:
- type: posgtres
+ type: postgres
name: Postgres Source
hostname: 127.0.0.1
port: 5432
username: admin
password: pass
- tables: adb.\.*.\.*, bdb.user_schema_[0-9].user_table_[0-9]+,
[app|web].schema_\.*.order_\.*
+ # make sure all the tables share same database.
+ tables: adb.\.*.\.*
decoding.plugin.name: pgoutput
slot.name: pgtest
sink:
- type: doris
- name: Doris Sink
- fenodes: 127.0.0.1:8030
- username: root
- password: pass
+ type: fluss
+ name: Fluss Sink
+ bootstrap.servers: localhost:9123
+ # Security-related properties for the Fluss client
+ properties.client.security.protocol: sasl
+ properties.client.security.sasl.mechanism: PLAIN
+ properties.client.security.sasl.username: developer
+ properties.client.security.sasl.password: developer-pass
pipeline:
- name: Postgres to Doris Pipeline
+ name: Postgres to Fluss Pipeline
parallelism: 4
```
@@ -106,9 +110,10 @@ pipeline:
<td style="word-wrap: break-word;">(none)</td>
<td>String</td>
<td>Table name of the Postgres database to monitor. The table-name also
supports regular expressions to monitor multiple tables that satisfy the
regular expressions. <br>
- It is important to note that the dot (.) is treated as a delimiter
for database and table names.
+ All the tables are required to share same database. <br>
+ It is important to note that the dot (.) is treated as a delimiter
for database, schema and table names.
If there is a need to use a dot (.) in a regular expression to match
any character, it is necessary to escape the dot with a backslash.<br>
- 例如，adb.\.*.\.*, bdb.user_schema_[0-9].user_table_[0-9]+,
[app|web].schema_\.*.order_\.*</td>
+ for example: bdb.user_schema_[0-9].user_table_[0-9]+,
bdb.schema_\.*.order_\.*</td>
</tr>
<tr>
<td>slot.name</td>
