This is an automated email from the ASF dual-hosted git repository.
wanghailin 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 45bbaf543e [Fix][Doc] Update Elasticsearch Sink and Oracle CDC Source
Sample Configuration (#8425)
45bbaf543e is described below
commit 45bbaf543ed8ef27a4c96f8e7d5e0d1c0201be28
Author: 不忘初心 <[email protected]>
AuthorDate: Thu Jan 2 18:17:37 2025 +0800
[Fix][Doc] Update Elasticsearch Sink and Oracle CDC Source Sample
Configuration (#8425)
---
docs/en/connector-v2/sink/Elasticsearch.md | 29 +++++++++++-
docs/en/connector-v2/source/Oracle-CDC.md | 75 ++++++++++++++----------------
docs/zh/connector-v2/sink/Elasticsearch.md | 30 +++++++++++-
3 files changed, 91 insertions(+), 43 deletions(-)
diff --git a/docs/en/connector-v2/sink/Elasticsearch.md
b/docs/en/connector-v2/sink/Elasticsearch.md
index 7d83665785..50467237c1 100644
--- a/docs/en/connector-v2/sink/Elasticsearch.md
+++ b/docs/en/connector-v2/sink/Elasticsearch.md
@@ -126,7 +126,7 @@ Option introduction：
Simple
-```bash
+```conf
sink {
Elasticsearch {
hosts = ["localhost:9200"]
@@ -134,11 +134,23 @@ sink {
schema_save_mode="IGNORE"
}
}
+
+```
+Multi-table writing
+
+```conf
+sink {
+ Elasticsearch {
+ hosts = ["localhost:9200"]
+ index = "${table_name}"
+ schema_save_mode="IGNORE"
+ }
+}
```
CDC(Change data capture) event
-```bash
+```conf
sink {
Elasticsearch {
hosts = ["localhost:9200"]
@@ -148,6 +160,19 @@ sink {
primary_keys = ["key1", "key2", ...]
}
}
+
+```
+CDC(Change data capture) event Multi-table writing
+
+```conf
+sink {
+ Elasticsearch {
+ hosts = ["localhost:9200"]
+ index = "${table_name}"
+ schema_save_mode="IGNORE"
+ primary_keys = ["${primary_key}"]
+ }
+}
```
SSL (Disable certificates validation)
diff --git a/docs/en/connector-v2/source/Oracle-CDC.md
b/docs/en/connector-v2/source/Oracle-CDC.md
index 988bbff988..9d85c3a30c 100644
--- a/docs/en/connector-v2/source/Oracle-CDC.md
+++ b/docs/en/connector-v2/source/Oracle-CDC.md
@@ -292,6 +292,24 @@ source {
password = "oracle"
database-names = ["XE"]
schema-names = ["DEBEZIUM"]
+ table-names = ["XE.DEBEZIUM.FULL_TYPES", "XE.DEBEZIUM.FULL_TYPES2"]
+ base-url = "jdbc:oracle:thin:@oracle-host:1521:xe"
+ source.reader.close.timeout = 120000
+ }
+}
+```
+
+> Use the select count(*) instead of analysis table for count table rows in
full stage
+```conf
+source {
+# This is a example source plugin **only for test and demonstrate the feature
source plugin**
+ Oracle-CDC {
+ plugin_output = "customers"
+ use_select_count = true
+ username = "system"
+ password = "oracle"
+ database-names = ["XE"]
+ schema-names = ["DEBEZIUM"]
table-names = ["XE.DEBEZIUM.FULL_TYPES"]
base-url = "jdbc:oracle:thin:system/oracle@oracle-host:1521:xe"
source.reader.close.timeout = 120000
@@ -299,48 +317,28 @@ source {
}
```
-> Use the select count(*) instead of analysis table for count table rows in
full stage
->
-> ```conf
-> source {
-> # This is a example source plugin **only for test and demonstrate the
feature source plugin**
-> Oracle-CDC {
-> plugin_output = "customers"
-> use_select_count = true
-> username = "system"
-> password = "oracle"
-> database-names = ["XE"]
-> schema-names = ["DEBEZIUM"]
-> table-names = ["XE.DEBEZIUM.FULL_TYPES"]
-> base-url = "jdbc:oracle:thin:system/oracle@oracle-host:1521:xe"
-> source.reader.close.timeout = 120000
-> }
-> }
-> ```
->
> Use the select NUM_ROWS from all_tables for the table rows but skip the
> analyze table.
->
-> ```conf
-> source {
-> # This is a example source plugin **only for test and demonstrate the
feature source plugin**
-> Oracle-CDC {
-> plugin_output = "customers"
-> skip_analyze = true
-> username = "system"
-> password = "oracle"
-> database-names = ["XE"]
-> schema-names = ["DEBEZIUM"]
-> table-names = ["XE.DEBEZIUM.FULL_TYPES"]
-> base-url = "jdbc:oracle:thin:system/oracle@oracle-host:1521:xe"
-> source.reader.close.timeout = 120000
-> }
-> }
-> ```
-
-### Support custom primary key for table
+```conf
+source {
+# This is a example source plugin **only for test and demonstrate the feature
source plugin**
+ Oracle-CDC {
+ plugin_output = "customers"
+ skip_analyze = true
+ username = "system"
+ password = "oracle"
+ database-names = ["XE"]
+ schema-names = ["DEBEZIUM"]
+ table-names = ["XE.DEBEZIUM.FULL_TYPES"]
+ base-url = "jdbc:oracle:thin:system/oracle@oracle-host:1521:xe"
+ source.reader.close.timeout = 120000
+ }
+}
```
+### Support custom primary key for table
+
+```conf
source {
Oracle-CDC {
plugin_output = "customers"
@@ -359,7 +357,6 @@ source {
]
}
}
-
```
### Support debezium-compatible format send to kafka
diff --git a/docs/zh/connector-v2/sink/Elasticsearch.md
b/docs/zh/connector-v2/sink/Elasticsearch.md
index 2f35165f52..97c9519bbf 100644
--- a/docs/zh/connector-v2/sink/Elasticsearch.md
+++ b/docs/zh/connector-v2/sink/Elasticsearch.md
@@ -125,7 +125,7 @@ Sink插件常用参数，请参考 [Sink常用选项](../sink-common-options.md)
简单示例
-```bash
+```conf
sink {
Elasticsearch {
hosts = ["localhost:9200"]
@@ -135,9 +135,21 @@ sink {
}
```
+多表写入
+
+```conf
+sink {
+ Elasticsearch {
+ hosts = ["localhost:9200"]
+ index = "${table_name}"
+ schema_save_mode="IGNORE"
+ }
+}
+```
+
变更数据捕获 (Change data capture) 事件
-```bash
+```conf
sink {
Elasticsearch {
hosts = ["localhost:9200"]
@@ -149,6 +161,20 @@ sink {
}
```
+```
+变更数据捕获 (Change data capture) 事件多表写入
+
+```conf
+sink {
+ Elasticsearch {
+ hosts = ["localhost:9200"]
+ index = "${table_name}"
+ schema_save_mode="IGNORE"
+ primary_keys = ["${primary_key}"]
+ }
+}
+```
+
SSL 禁用证书验证
```hocon
