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 20fa3babb5 [Doc][Improve] support chinese
[docs/zh/connector-v2/sink/Sentry.md] #8497 (#8672)
20fa3babb5 is described below
commit 20fa3babb5df88cc2f60e683ad9eccb151e8bf91
Author: mickeyzzm <[email protected]>
AuthorDate: Thu Feb 13 13:07:43 2025 +0800
[Doc][Improve] support chinese [docs/zh/connector-v2/sink/Sentry.md] #8497
(#8672)
---
docs/zh/connector-v2/sink/Activemq.md | 123 +++++++++++++++
docs/zh/connector-v2/sink/AmazonDynamoDB.md | 66 ++++++++
docs/zh/connector-v2/sink/AmazonSqs.md | 87 +++++++++++
docs/zh/connector-v2/sink/Cassandra.md | 94 ++++++++++++
docs/zh/connector-v2/sink/DB2.md | 175 +++++++++++++++++++++
docs/zh/connector-v2/sink/Datahub.md | 79 ++++++++++
docs/zh/connector-v2/sink/Druid.md | 83 ++++++++++
docs/zh/connector-v2/sink/Easysearch.md | 202 +++++++++++++++++++++++++
docs/zh/connector-v2/sink/Enterprise-WeChat.md | 75 +++++++++
docs/zh/connector-v2/sink/Redshift.md | 98 ++++++++++++
docs/zh/connector-v2/sink/Sentry.md | 78 ++++++++++
11 files changed, 1160 insertions(+)
diff --git a/docs/zh/connector-v2/sink/Activemq.md
b/docs/zh/connector-v2/sink/Activemq.md
new file mode 100644
index 0000000000..aa7d2446d0
--- /dev/null
+++ b/docs/zh/connector-v2/sink/Activemq.md
@@ -0,0 +1,123 @@
+# Activemq
+
+> Activemq 接收器连接器
+
+## 描述
+
+用于将数据写入 Activemq.
+
+## 关键特性
+
+- [ ] [精确一次](../../concept/connector-v2-features.md)
+
+## 选项
+
+| 名称 | 类型 | 必需 | 默认值 |
+|-------------------------------------|---------|-----|--------------|
+| host | string | 否 | - |
+| port | int | 否 | - |
+| virtual_host | string | 否 | - |
+| username | string | 否 | - |
+| password | string | 否 | - |
+| queue_name | string | 是 | - |
+| uri | string | 是 | - |
+| check_for_duplicate | boolean | 否 | - |
+| client_id | boolean | 否 | - |
+| copy_message_on_send | boolean | 否 | - |
+| disable_timeStamps_by_default | boolean | 否 | - |
+| use_compression | boolean | 否 | - |
+| always_session_async | boolean | 否 | - |
+| dispatch_async | boolean | 否 | - |
+| nested_map_and_list_enabled | boolean | 否 | - |
+| warnAboutUnstartedConnectionTimeout | boolean | 否 | - |
+| closeTimeout | int | 否 | - |
+
+### host [string]
+
+用于连接的默认主机.
+
+### port [int]
+
+用于连接的默认端口
+
+### username [string]
+
+用于连接的默认端口
+
+### password [string]
+
+连接到代理时使用的密码
+
+### uri [string]
+
+用于设置 AMQP URI 中字段（主机、端口、用户名、密码和虚拟主机）的便捷方法
+
+### queue_name [string]
+
+写入消息的队列
+
+### check_for_duplicate [boolean]
+
+将检查重复消息
+
+### client_id [string]
+
+客户端ID
+
+### copy_message_on_send [boolean]
+
+如果为true，则启用新的JMS消息对象作为发送方法的一部分
+
+### disable_timeStamps_by_default [boolean]
+
+禁用时间戳以获得轻微的性能提升.
+
+### use_compression [boolean]
+
+允许对消息正文使用压缩.
+
+### always_session_async [boolean]
+
+当为true时，将使用单独的线程为连接中的每个会话分派消息.
+
+### always_sync_send [boolean]
+
+当为true时，MessageProducer在发送消息时将始终使用同步发送
+
+### close_timeout [boolean]
+
+设置关闭完成前的超时时间（以毫秒为单位）.
+
+### dispatch_async [boolean]
+
+代理是否应该异步地向消费者发送消息
+
+### nested_map_and_list_enabled [boolean]
+
+控制是否支持结构化消息属性和MapMessages
+
+### warn_about_unstarted_connection_timeout [int]
+
+从创建连接到生成警告的超时时间（毫秒）
+
+## 示例
+
+简单:
+
+```hocon
+sink {
+ ActiveMQ {
+ uri="tcp://localhost:61616"
+ username = "admin"
+ password = "admin"
+ queue_name = "test1"
+ }
+}
+```
+
+## 变更日志
+
+### 下一个版本
+
+- 添加Activemq源连接器
+
diff --git a/docs/zh/connector-v2/sink/AmazonDynamoDB.md
b/docs/zh/connector-v2/sink/AmazonDynamoDB.md
new file mode 100644
index 0000000000..67bfa89703
--- /dev/null
+++ b/docs/zh/connector-v2/sink/AmazonDynamoDB.md
@@ -0,0 +1,66 @@
+# AmazonDynamoDB
+
+> Amazon DynamoDB 接收器连接器
+
+## 描述
+
+将数据写入 Amazon DynamoDB
+
+## 关键特性
+
+- [ ] [精确一次](../../concept/connector-v2-features.md)
+
+## 选项
+
+| 名称 | 类型 | 必需 | 默认值 |
+|-------------------|--------|----|---------------|
+| url | string | 是 | - |
+| region | string | 是 | - |
+| access_key_id | string | 是 | - |
+| secret_access_key | string | 是 | - |
+| table | string | 是 | - |
+| batch_size | string | 否 | 25 |
+| common-options | | 否 | - |
+
+### url [string]
+
+要写入Amazon DynamoDB的URL.
+
+### region [string]
+
+Amazon DynamoDB 的分区.
+
+### accessKeyId [string]
+
+Amazon DynamoDB的访问id.
+
+### secretAccessKey [string]
+
+Amazon DynamoDB的访问密钥.
+
+### table [string]
+
+Amazon DynamoDB 的表名.
+
+### 常见选项
+
+Sink插件常用参数，请参考 [Sink Common Options](../sink-common-options.md) 了解详细信息.
+
+## 示例
+
+```bash
+Amazondynamodb {
+ url = "http://127.0.0.1:8000";
+ region = "us-east-1"
+ accessKeyId = "dummy-key"
+ secretAccessKey = "dummy-secret"
+ table = "TableName"
+ }
+```
+
+## 变更日志
+
+### 下一个版本
+
+- 添加 Amazon DynamoDB 接收器连接器
+
diff --git a/docs/zh/connector-v2/sink/AmazonSqs.md
b/docs/zh/connector-v2/sink/AmazonSqs.md
new file mode 100644
index 0000000000..b0e425ed39
--- /dev/null
+++ b/docs/zh/connector-v2/sink/AmazonSqs.md
@@ -0,0 +1,87 @@
+# AmazonSqs
+
+> Amazon SQS 接收器连接器
+
+## 支持以下引擎
+
+> Spark<br/>
+> Flink<br/>
+> SeaTunnel Zeta<br/>
+
+## 描述
+
+将数据写入 Amazon SQS
+
+## 关键特性
+
+- [x] [批处理](../../concept/connector-v2-features.md)
+- [x] [流处理](../../concept/connector-v2-features.md)
+- [x] [精确一次](../../concept/connector-v2-features.md)
+- [ ] [列映射](../../concept/connector-v2-features.md)
+- [ ] [并行性](../../concept/connector-v2-features.md)
+- [ ] [支持用户定义的拆分](../../concept/connector-v2-features.md)
+
+## 参数和选项
+
+| 名称 | 类型 | 必需 | 默认值 |
Description
|
+|-------------------------|--------|--|---------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| url | String | 是 | - | 从Amazon SQS读取的队列URL.
|
+| region | String | 否 | - | SQS服务的AWS区域
|
+| format | String | 否 | json | 数据格式。默认格式为json。可选文本格式，canal
json和debezium
json。如果你使用json或文本格式。默认字段分隔符为“，”。如果自定义分隔符，请添加“field_delimiter”选项。如果您使用canal格式，请参阅[canal-json]（../formats/canal-json.md）了解详细信息。如果您使用debezium格式，请参阅[debezium
json]（../formats/debezium json.md）了解详细信息. |
+| format_error_handle_way | String | 否 | fail |
数据格式错误的处理方法。默认值为fail，可选值为（fail，skip）。当选择失败时，数据格式错误将被阻止，并引发异常。当选择跳过时，数据格式错误将跳过此行数据.
|
+| field_delimiter | String | 否 | , | 自定义数据格式的字段分隔符.
|
+
+## 任务示例
+
+```bash
+source {
+ FakeSource {
+ schema = {
+ fields {
+ c_map = "map<string, string>"
+ c_array = "array<int>"
+ c_string = string
+ c_boolean = boolean
+ c_tinyint = tinyint
+ c_smallint = smallint
+ c_int = int
+ c_bigint = bigint
+ c_float = float
+ c_double = double
+ c_bytes = bytes
+ c_date = date
+ c_decimal = "decimal(38, 18)"
+ c_timestamp = timestamp
+ c_row = {
+ c_map = "map<string, string>"
+ c_array = "array<int>"
+ c_string = string
+ c_boolean = boolean
+ c_tinyint = tinyint
+ c_smallint = smallint
+ c_int = int
+ c_bigint = bigint
+ c_float = float
+ c_double = double
+ c_bytes = bytes
+ c_date = date
+ c_decimal = "decimal(38, 18)"
+ c_timestamp = timestamp
+ }
+ }
+ }
+ plugin_output = "fake"
+ }
+}
+
+sink {
+ AmazonSqs {
+ url = "http://127.0.0.1:8000";
+ region = "us-east-1"
+ queue = "queueName"
+ format = text
+ field_delimiter = "|"
+ }
+}
+```
+
diff --git a/docs/zh/connector-v2/sink/Cassandra.md
b/docs/zh/connector-v2/sink/Cassandra.md
new file mode 100644
index 0000000000..13222eed0d
--- /dev/null
+++ b/docs/zh/connector-v2/sink/Cassandra.md
@@ -0,0 +1,94 @@
+# Cassandra
+
+> Cassandra 接收器连接器
+
+## 描述
+
+将数据写入 Apache Cassandra.
+
+## 关键特性
+
+- [ ] [精确一次](../../concept/connector-v2-features.md)
+
+## 选项
+
+| 名称 | 类型 | 必需 | 默认值 |
+|-------------------|---------|----|---------------|
+| host | String | 是 | - |
+| keyspace | String | 是 | - |
+| table | String | 是 | - |
+| username | String | 否 | - |
+| password | String | 否 | - |
+| datacenter | String | 否 | datacenter1 |
+| consistency_level | String | 否 | LOCAL_ONE |
+| fields | Array | 否 | - |
+| batch_size | int | 否 | 5000 |
+| batch_type | String | 否 | UNLOGGED |
+| async_write | boolean | 否 | true |
+
+### host [string]
+
+`Cassandra` 的集群地址，格式为 `host:port` , 允许指定多个 `hosts` . 例如
+`"cassandra1:9042,cassandra2:9042"`.
+
+### keyspace [string]
+
+`Cassandra` 键空间.
+
+### table [String]
+
+`Cassandra` 的表名.
+
+### username [string]
+
+`Cassandra` 用户的用户名.
+
+### password [string]
+
+`Cassandra` 用户的密码.
+
+### datacenter [String]
+
+`Cassandra` 的数据中心, 默认为 `datacenter1`.
+
+### consistency_level [String]
+
+`Cassandra` 写入一致性级别, 默认为 `LOCAL_ONE`.
+
+### fields [array]
+
+需要输出到 `Cassandra` 的数据字段, 如果未配置, 如果未配置，它将自动适应 sink 表 `schema`.
+
+### batch_size [number]
+
+通过 [Cassandra-Java-Driver](https://github.com/datastax/java-driver) 每次写入的行数,
+默认值 `5000`.
+
+### batch_type [String]
+
+`Cassandra` 批处理模式, 默认值 `UNLOGGER`.
+
+### async_write [boolean]
+
+`cassandra` 是否以异步模式写入, 默认值 `true`.
+
+## 示例
+
+```hocon
+sink {
+ Cassandra {
+ host = "localhost:9042"
+ username = "cassandra"
+ password = "cassandra"
+ datacenter = "datacenter1"
+ keyspace = "test"
+ }
+}
+```
+
+## 变更日志
+
+### 下一个版本
+
+- 添加 Cassandra 接收器连接器
+
diff --git a/docs/zh/connector-v2/sink/DB2.md b/docs/zh/connector-v2/sink/DB2.md
new file mode 100644
index 0000000000..23703e41dc
--- /dev/null
+++ b/docs/zh/connector-v2/sink/DB2.md
@@ -0,0 +1,175 @@
+# DB2
+
+> JDBC DB2接收器连接器
+
+## 支持以下引擎
+
+> Spark<br/>
+> Flink<br/>
+> SeaTunnel Zeta<br/>
+
+## 描述
+
+通过jdbc写入数据。支持批处理模式和流模式，支持并发写入，只支持一次
+语义（使用XA事务保证）.
+
+## 使用依赖关系
+
+### 适用于 Spark/Flink 引擎
+
+> 1. 您需要确保 [jdbc driver jar
package](https://mvnrepository.com/artifact/com.ibm.db2.jcc/db2jcc) 已放置在目录
`${SEATUNNEL_HOME}/plugins/`.
+
+### 适用于 SeaTunnel Zeta 引擎
+
+> 1. 您需要确保 [jdbc driver jar
package](https://mvnrepository.com/artifact/com.ibm.db2.jcc/db2jcc) 已放置在目录
`${SEATUNNEL_HOME}/lib/`.
+
+## 关键特性
+
+- [x] [精确一次](../../concept/connector-v2-features.md)
+- [ ] [cdc](../../concept/connector-v2-features.md)
+
+> 使用 `Xa transactions` 来确保 `精确一次`. 因此，数据库只支持 `exactly-once` 即
+> 支持 `Xa transactions`. 您可以设置 `is_exactly_once=true` 来启用它.
+
+## 支持的数据源信息
+
+| 数据库 | 支持版本 | 驱动
| Url | Maven
|
+|------------|---------------------------------------------------------|--------------------------------|-----------------------------------|-----------------------------------------------------------------------|
+| DB2 | Different dependency version has different driver class. |
com.ibm.db2.jdbc.app.DB2Driver | jdbc:db2://127.0.0.1:50000/dbname |
[Download](https://mvnrepository.com/artifact/com.ibm.db2.jcc/db2jcc) |
+
+## 数据类型映射
+
+| DB2数据类型
| SeaTunnel 数据类型 |
+|------------------------------------------------------------------------------------------------------|---------------------|
+| BOOLEAN
| BOOLEAN |
+| SMALLINT
| SHORT |
+| INT<br/>INTEGER<br/>
| INTEGER |
+| BIGINT
| LONG |
+| DECIMAL<br/>DEC<br/>NUMERIC<br/>NUM
| DECIMAL(38,18) |
+| REAL
| FLOAT |
+| FLOAT<br/>DOUBLE<br/>DOUBLE PRECISION<br/>DECFLOAT
| DOUBLE |
+| CHAR<br/>VARCHAR<br/>LONG
VARCHAR<br/>CLOB<br/>GRAPHIC<br/>VARGRAPHIC<br/>LONG VARGRAPHIC<br/>DBCLOB |
STRING |
+| BLOB
| BYTES |
+| DATE
| DATE |
+| TIME
| TIME |
+| TIMESTAMP
| TIMESTAMP |
+| ROWID<br/>XML
| Not supported yet |
+
+## 选项
+
+| 名称 | 类型 | 必需 | 默认值 | 描述
|
+|-------------------------------------------|---------|----------|---------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| url | String | Yes | - |
JDBC连接的URL。请参考案例 : jdbc:db2://127.0.0.1:50000/dbname
|
+| driver | String | Yes | - |
用于连接到远程数据源的jdbc类名,<br/> 如果使用DB2，则值为 `com.ibm.db2.jdbc.app.DB2Driver`.
|
+| user | String | No | - |
连接实例用户名
|
+| password | String | No | - |
连接实例密码
|
+| query | String | No | - |
使用此sql将上游输入数据写入数据库。例如 `INSERT ...`,`query` 具有更高的优先级
|
+| database | String | No | - |
使用这个 `database` 和 `table-name` 自动生成sql并接收上游输入数据写入数据库.<br/>此选项与 `query`
互斥，具有更高的优先级.
|
+| table | String | No | - |
使用数据库和此表名自动生成sql并接收上游输入数据写入数据库.<br/>此选项与 `query` 互斥，具有更高的优先级.
|
+| primary_keys | Array | No | - |
此选项用于在自动生成sql时支持 `insert`, `delete`, 和 `update` 等操作.
|
+| support_upsert_by_query_primary_key_exist | Boolean | No | false |
选择使用INSERT sql、UPDATE sql根据查询主键是否存在来处理更新事件(INSERT, UPDATE_AFTER).
此配置仅在数据库不支持升级语法时使用. **注**: 此方法性能低
|
+| connection_check_timeout_sec | Int | No | 30 |
等待用于验证连接的数据库操作完成的时间（秒）.
|
+| max_retries | Int | No | 0 |
提交失败的重试次数 (执行批处理)
|
+| batch_size | Int | No | 1000 |
对于批量写入，当缓冲记录的数量达到 `batch_size` 的数量或时间达到 `checkpoint.interval` 时<br/>,
数据将被刷新到数据库中
|
+| is_exactly_once | Boolean | No | false |
是否启用精确一次语义，这将使用 Xa 事务. 如果启用，则需要<br/>设置 `xa_data_source_class_name`.
|
+| generate_sink_sql | Boolean | No | false |
根据要写入的数据库表生成sql语句
|
+| xa_data_source_class_name | String | No | - |
数据库Driver的 xa 数据源类名, for example, DB2 是 `com.db2.cj.jdbc.Db2XADataSource`,
<br/>其他数据来源请参考附录
|
+| max_commit_attempts | Int | No | 3 |
事务提交失败的重试次数
|
+| transaction_timeout_sec | Int | No | -1 |
事务打开后的超时，默认值为-1（永不超时）. 请注意，设置超时可能会影响＜br/＞精确一次语义
|
+| auto_commit | Boolean | No | true |
默认情况下启用自动事务提交
|
+| properties | Map | No | - |
附加连接配置参数，当属性和URL具有相同的参数时，优先级由驱动程序的特定实现决定. 例如，在MySQL中，属性优先于URL. |
+| common-options | | no | - |
Sink插件常用参数，详见 [Sink Common Options](../sink-common-options.md)
|
+
+### 小贴士
+
+> 如果未设置partition_column，它将以单并发运行，如果设置了partition_coolumn，它将根据任务的并发性并行执行.
+
+## 任务示例
+
+### 简单:
+
+> 此示例定义了一个SeaTunnel同步任务，该任务通过FakeSource自动生成数据并将其发送到JDBC
Sink。FakeSource总共生成16行数据（row.num=16），每行有两个字段，name（字符串类型）和age（int类型）。最终的目标表是test_table，表中也将有16行数据。在运行此作业之前，您需要在DB2中创建数据库测试和表test_table。如果您尚未安装和部署SeaTunnel，则需要按照[Install
SeaTunnel](../../start-v2/locally/deployment.md)中的说明安装和部署SeaTunnel。然后按照[Quick
Start With SeaTunnel
Engine](../../start-v2/locally/quick-start-seatunnel-engine.md) 中的说明运行此作业.
+
+```
+# 定义运行时环境
+env {
+ parallelism = 1
+ job.mode = "BATCH"
+}
+
+source {
+ # 这是一个示例源插件 **仅用于测试和演示功能源插件**
+ FakeSource {
+ parallelism = 1
+ plugin_output = "fake"
+ row.num = 16
+ schema = {
+ fields {
+ name = "string"
+ age = "int"
+ }
+ }
+ }
+ # 如果你想了解更多关于如何配置seatunnel的信息，并查看完整的源插件列表,
+ # 请前往 https://seatunnel.apache.org/docs/connector-v2/source
+}
+
+transform {
+ # 如果你想了解更多关于如何配置seatunnel的信息，并查看转换插件的完整列表
+ # 请前往 https://seatunnel.apache.org/docs/category/transform-v2
+}
+
+sink {
+ jdbc {
+ url = "jdbc:db2://127.0.0.1:50000/dbname"
+ driver = "com.ibm.db2.jdbc.app.DB2Driver"
+ user = "root"
+ password = "123456"
+ query = "insert into test_table(name,age) values(?,?)"
+ }
+ # 如果你想了解更多关于如何配置seatunnel的信息，并查看完整的接收插件列表,
+ # 请前往 https://seatunnel.apache.org/docs/connector-v2/sink
+}
+```
+
+### 生成 Sink SQL
+
+> 此示例不需要编写复杂的sql语句，您可以配置数据库名称表名以自动为您生成add语句
+
+```
+sink {
+ jdbc {
+ url = "jdbc:db2://127.0.0.1:50000/dbname"
+ driver = "com.ibm.db2.jdbc.app.DB2Driver"
+ user = "root"
+ password = "123456"
+ # Automatically generate sql statements based on database table names
+ generate_sink_sql = true
+ database = test
+ table = test_table
+ }
+}
+```
+
+### 精确一次 :
+
+> 为了准确的书写场景，我们保证一次准确
+
+```
+sink {
+ jdbc {
+ url = "jdbc:db2://127.0.0.1:50000/dbname"
+ driver = "com.ibm.db2.jdbc.app.DB2Driver"
+
+ max_retries = 0
+ user = "root"
+ password = "123456"
+ query = "insert into test_table(name,age) values(?,?)"
+
+ is_exactly_once = "true"
+
+ xa_data_source_class_name = "com.db2.cj.jdbc.Db2XADataSource"
+ }
+}
+```
+
diff --git a/docs/zh/connector-v2/sink/Datahub.md
b/docs/zh/connector-v2/sink/Datahub.md
new file mode 100644
index 0000000000..8656c3fa29
--- /dev/null
+++ b/docs/zh/connector-v2/sink/Datahub.md
@@ -0,0 +1,79 @@
+# DataHub
+
+> DataHub 接收器连接器
+
+## 描述
+
+一个使用向 DataHub 发送消息的接收器插件
+
+## 关键特性
+
+- [ ] [精确一次](../../concept/connector-v2-features.md)
+
+## 选项
+
+| 名称 | 类型 | 必需 | 默认值 |
+|----------------|--------|----|---------------|
+| endpoint | string | 是 | - |
+| accessId | string | 是 | - |
+| accessKey | string | 是 | - |
+| project | string | 是 | - |
+| topic | string | 是 | - |
+| timeout | int | 是 | - |
+| retryTimes | int | 是 | - |
+| common-options | | 否 | - |
+
+### endpoint [string]
+
+您的DataHub端点以http开头
+
+### accessId [string]
+
+您的DataHub accessId可以从阿里云访问哪个云
+
+### accessKey[string]
+
+您的DataHub accessKey可以从阿里云访问哪个云
+
+### project [string]
+
+您在阿里云中创建的DataHub项目
+
+### topic [string]
+
+您的DataHub主题
+
+### timeout [int]
+
+最大连接超时
+
+### retryTimes [int]
+
+客户端放置记录失败时的最大重试次数
+
+### common options
+
+接收器插件常用参数，详见 [Sink Common Options](../sink-common-options.md)
+
+## 示例
+
+```hocon
+sink {
+ DataHub {
+ endpoint="yourendpoint"
+ accessId="xxx"
+ accessKey="xxx"
+ project="projectname"
+ topic="topicname"
+ timeout=3000
+ retryTimes=3
+ }
+}
+```
+
+## 变更日志
+
+### 2.2.0-beta 2022-09-26
+
+- 添加DataHub接收器连接器
+
diff --git a/docs/zh/connector-v2/sink/Druid.md
b/docs/zh/connector-v2/sink/Druid.md
new file mode 100644
index 0000000000..20c2cf24a4
--- /dev/null
+++ b/docs/zh/connector-v2/sink/Druid.md
@@ -0,0 +1,83 @@
+# Druid
+
+> Druid 接收器连接器
+
+## 描述
+
+一个使用向 Druid 发送消息的接收器插件
+
+## 关键特性
+
+- [ ] [精确一次](../../concept/connector-v2-features.md)
+- [x] [支持多表写入](../../concept/connector-v2-features.md)
+
+## 数据类型映射
+
+| SeaTunnel 数据类型 | Druid 数据类型 |
+|----------------|-----------------|
+| TINYINT | LONG |
+| SMALLINT | LONG |
+| INT | LONG |
+| BIGINT | LONG |
+| FLOAT | FLOAT |
+| DOUBLE | DOUBLE |
+| DECIMAL | DOUBLE |
+| STRING | STRING |
+| BOOLEAN | STRING |
+| TIMESTAMP | STRING |
+
+## 选项
+
+| 名称 | 类型 | 必需 | 默认值 |
+|----------------|--------|----|---------------|
+| coordinatorUrl | string | 是 | - |
+| datasource | string | 是 | - |
+| batchSize | int | 否 | 10000 |
+| common-options | | 否 | - |
+
+### coordinatorUrl [string]
+
+Druid的协调器URL主机和端口，示例: "myHost:8888"
+
+### datasource [string]
+
+要写入的数据源名称，示例: "seatunnel"
+
+### batchSize [int]
+
+每批刷新为Druid的行数。默认值为 `1024`.
+
+### common options
+
+Sink插件常用参数，详见 [Sink Common Options](../sink-common-options.md) for details
+
+## 示例
+
+简单的例子:
+
+```hocon
+sink {
+ Druid {
+ coordinatorUrl = "testHost:8888"
+ datasource = "seatunnel"
+ }
+}
+```
+
+使用占位符获取上游表元数据示例:
+
+```hocon
+sink {
+ Druid {
+ coordinatorUrl = "testHost:8888"
+ datasource = "${table_name}_test"
+ }
+}
+```
+
+## 变更日志
+
+### 下一个版本
+
+- 添加 Druid 接收器连接器
+
diff --git a/docs/zh/connector-v2/sink/Easysearch.md
b/docs/zh/connector-v2/sink/Easysearch.md
new file mode 100644
index 0000000000..eebeb157c5
--- /dev/null
+++ b/docs/zh/connector-v2/sink/Easysearch.md
@@ -0,0 +1,202 @@
+# INFINI Easysearch
+
+## 支持以下引擎
+
+> Spark<br/>
+> Flink<br/>
+> SeaTunnel Zeta<br/>
+
+## 描述
+
+一个使用将数据发送到 `INFINI Easysearch` 的接收器插件.
+
+## 使用依赖
+
+> 依赖
[easysearch-client](https://central.sonatype.com/artifact/com.infinilabs/easysearch-client)
+>
+ ## 关键特性
+
+- [ ] [精确一次](../../concept/connector-v2-features.md)
+- [x] [cdc](../../concept/connector-v2-features.md)
+
+:::提示
+
+支持的引擎
+
+* 支持 [INFINI Easysearch](https://www.infini.com/download/?product=easysearch)
发布的所有版本.
+
+:::
+
+## 数据类型映射
+
+| Easysearch 数据类型 | SeaTunnel 数据类型 |
+|-----------------------------|----------------------|
+| STRING<br/>KEYWORD<br/>TEXT | STRING |
+| BOOLEAN | BOOLEAN |
+| BYTE | BYTE |
+| SHORT | SHORT |
+| INTEGER | INT |
+| LONG | LONG |
+| FLOAT<br/>HALF_FLOAT | FLOAT |
+| DOUBLE | DOUBLE |
+| Date | LOCAL_DATE_TIME_TYPE |
+
+## 接收器选项
+
+| 名称 | 类型 | 必需 | 默认值 |
+|-------------------------|---------|----|---------------|
+| hosts | array | 是 | - |
+| index | string | 是 | - |
+| primary_keys | list | 否 | |
+| key_delimiter | string | 否 | `_` |
+| username | string | 否 | |
+| password | string | 否 | |
+| max_retry_count | int | 否 | 3 |
+| max_batch_size | int | 否 | 10 |
+| tls_verify_certificate | boolean | 否 | true |
+| tls_verify_hostnames | boolean | 否 | true |
+| tls_keystore_path | string | 否 | - |
+| tls_keystore_password | string | 否 | - |
+| tls_truststore_path | string | 否 | - |
+| tls_truststore_password | string | 否 | - |
+| common-options | | 否 | - |
+
+### hosts [array]
+
+`INFINI Easysearch` 集群http地址，格式为 `host:port` , 允许指定多个主机.例如 `["host1:9200",
"host2:9200"]`.
+
+### index [string]
+
+`INFINI Easysearch` `index` 名称.索引支持包含字段名变量,例如
`seatunnel_${age}`,该字段必须出现在seatunnel行.
+如果没有，我们将把它当作一个正常的索引.
+
+### primary_keys [list]
+
+用于生成文档 `_id`的主键字段，这是cdc必需的选项.
+
+### key_delimiter [string]
+
+复合键的分隔符 (默认为"_" ), 例如, "$" 将导致文档 `_id` "KEY1$KEY2$KEY3".
+
+### username [string]
+
+安全用户名
+
+### password [string]
+
+安全密码
+
+### max_retry_count [int]
+
+一个批量请求的最大尝试大小
+
+### max_batch_size [int]
+
+批量文档最大大小
+
+### tls_verify_certificate [boolean]
+
+为HTTPS端点启用证书验证
+
+### tls_verify_hostname [boolean]
+
+为HTTPS端点启用主机名验证
+
+### tls_keystore_path [string]
+
+PEM或JKS密钥存储的路径。运行SeaTunnel的操作系统用户必须能够读取此文件.
+
+### tls_keystore_password [string]
+
+指定密钥存储的密钥密码
+
+### tls_truststore_path [string]
+
+PEM或JKS信任存储的路径。运行SeaTunnel的操作系统用户必须能够读取此文件.
+
+### tls_truststore_password [string]
+
+指定的信任存储的密钥密码
+
+### common options
+
+接收器插件常用参数，详见 [Sink Common Options](../sink-common-options.md)
+
+## 示例
+
+简单的例子
+
+```bash
+sink {
+ Easysearch {
+ hosts = ["localhost:9200"]
+ index = "seatunnel-${age}"
+ }
+}
+```
+
+CDC(变更数据捕获) 事件
+
+```bash
+sink {
+ Easysearch {
+ hosts = ["localhost:9200"]
+ index = "seatunnel-${age}"
+
+ # cdc required options
+ primary_keys = ["key1", "key2", ...]
+ }
+}
+```
+
+SSL (禁用证书验证)
+
+```hocon
+sink {
+ Easysearch {
+ hosts = ["https://localhost:9200";]
+ username = "admin"
+ password = "admin"
+
+ tls_verify_certificate = false
+ }
+}
+```
+
+SSL (禁用主机名验证)
+
+```hocon
+sink {
+ Easysearch {
+ hosts = ["https://localhost:9200";]
+ username = "admin"
+ password = "admin"
+
+ tls_verify_hostname = false
+ }
+}
+```
+
+SSL (启用证书验证)
+
+```hocon
+sink {
+ Easysearch {
+ hosts = ["https://localhost:9200";]
+ username = "admin"
+ password = "admin"
+
+ tls_keystore_path = "${your Easysearch home}/config/certs/http.p12"
+ tls_keystore_password = "${your password}"
+ }
+}
+```
+
+## 变更日志
+
+### 2.3.4 2023-11-16
+
+- 添加 Easysearch 接收器连接器
+- 支持http/https协议
+- 支持 CD C写入 DELETE/UPDATE/INSERT 事件
+
diff --git a/docs/zh/connector-v2/sink/Enterprise-WeChat.md
b/docs/zh/connector-v2/sink/Enterprise-WeChat.md
new file mode 100644
index 0000000000..d4285de651
--- /dev/null
+++ b/docs/zh/connector-v2/sink/Enterprise-WeChat.md
@@ -0,0 +1,75 @@
+# Enterprise WeChat
+
+> Enterprise WeChat 接收器连接器
+
+## 描述
+
+一个使用 Enterprise WeChat 机器人发送消息的接收插件
+
+> 例如，如果来自上游的数据是 [`"alarmStatus": "firing", "alarmTime": "2022-08-03
01:38:49"，"alarmContent": "The disk usage exceeds the threshold"`],
微信机器人的输出内容如下:
+>
+> ```
+> alarmStatus: firing
+> alarmTime: 2022-08-03 01:38:49
+> alarmContent: The disk usage exceeds the threshold
+> ```
+>
+> **小贴士: WeChat 接收器仅支持 `string` 类型 webhook ，源数据将被视为webhook中的正文内容.**
+
+## 关键特性
+
+- [ ] [精确一次](../../concept/connector-v2-features.md)
+
+## 选项
+
+| 名称 | 类型 | 必需 | 默认值 |
+|-----------------------|--------|----|---------------|
+| url | String | 是 | - |
+| mentioned_list | array | 否 | - |
+| mentioned_mobile_list | array | 否 | - |
+| common-options | | 否 | - |
+
+### url [string]
+
+企业微信网络挂钩 url 格式为
https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=XXXXXX（string）
+
+### mentioned_list [array]
+
+一个用户标识列表，用于提醒组中的指定成员（@A成员），@all意味着提醒每个人。如果开发人员无法获得用户ID，他可以使用called_mobile_list
+
+### mentioned_mobile_list [array]
+
+手机号码列表，提醒群组成员对应的手机号码（@a成员），@all表示提醒大家
+
+### common options
+
+接收器插件常用参数，详见 [Sink Common Options](../sink-common-options.md)
+
+## 示例
+
+简单的例子:
+
+```hocon
+WeChat {
+ url =
"https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=693axxx6-7aoc-4bc4-97a0-0ec2sifa5aaa";
+ }
+```
+
+```hocon
+WeChat {
+ url =
"https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=693axxx6-7aoc-4bc4-97a0-0ec2sifa5aaa";
+ mentioned_list=["wangqing","@all"]
+ mentioned_mobile_list=["13800001111","@all"]
+ }
+```
+
+## 变更日志
+
+### 2.2.0-beta 2022-09-26
+
+- 添加 Enterprise-WeChat 接收器连接器
+
+### 2.3.0-beta 2022-10-20
+
+- [Bug修复] 修复企业微信Sink数据序列化问题
([2856](https://github.com/apache/seatunnel/pull/2856))
+
diff --git a/docs/zh/connector-v2/sink/Redshift.md
b/docs/zh/connector-v2/sink/Redshift.md
new file mode 100644
index 0000000000..dd9e9c2afd
--- /dev/null
+++ b/docs/zh/connector-v2/sink/Redshift.md
@@ -0,0 +1,98 @@
+# Redshift
+
+> JDBC Redshift 接收器连接器
+
+## 支持以下引擎
+
+> Spark<br/>
+> Flink<br/>
+> Seatunnel Zeta<br/>
+
+## 关键特性
+
+- [x] [批处理](../../concept/connector-v2-features.md)
+- [x] [精确一次](../../concept/connector-v2-features.md)
+- [x] [更改数据捕获](../../concept/connector-v2-features.md)
+
+> 使用 `Xa transactions` 确保 `exactly-once`. 因此，数据库只支持 `exactly-once`
+> 即支持 `Xa transactions`. 您可以设置 `is_exactly_once=true` 来启用它.
+
+## 描述
+
+通过jdbc写入数据. 支持批处理模式和流模式，支持并发写入，只支持一次语义 (使用 XA transaction guarantee).
+
+## 支持的数据源列表
+
+| 数据源 | 支持版本 | 驱动
| url | maven
|
+|------------|----------------------------------------------------------|---------------------------------|-----------------------------------------|------------------------------------------------------------------------------|
+| redshift | 不同的依赖版本有不同的驱动程序类. | com.amazon.redshift.jdbc.Driver |
jdbc:redshift://localhost:5439/database |
[下载](https://mvnrepository.com/artifact/com.amazon.redshift/redshift-jdbc42) |
+
+## 数据库相关性
+
+### 适用于 Spark/Flink 引擎
+
+> 1. 您需要确保 [jdbc driver jar
package](https://mvnrepository.com/artifact/com.amazon.redshift/redshift-jdbc42)
已放置在目录 `${SEATUNNEL_HOME}/plugins/`.
+
+### 适用于 SeaTunnel Zeta 引擎
+
+> 1. 您需要确保 [jdbc driver jar
package](https://mvnrepository.com/artifact/com.amazon.redshift/redshift-jdbc42)
已放置在目录 `${SEATUNNEL_HOME}/lib/`.
+
+## 数据类型映射
+
+| SeaTunnel 数据类型 | Redshift 数据类型 |
+|-------------------------|--------------------|
+| BOOLEAN | BOOLEAN |
+| TINYINT<br/> SMALLINT | SMALLINT |
+| INT | INTEGER |
+| BIGINT | BIGINT |
+| FLOAT | REAL |
+| DOUBLE | DOUBLE PRECISION |
+| DECIMAL | NUMERIC |
+| STRING(<=65535) | CHARACTER VARYING |
+| STRING(>65535) | SUPER |
+| BYTES | BINARY VARYING |
+| TIME | TIME |
+| TIMESTAMP | TIMESTAMP |
+| MAP<br/> ARRAY<br/> ROW | SUPER |
+
+## 任务示例
+
+### 简单示例:
+
+```
+sink {
+ jdbc {
+ url = "jdbc:redshift://localhost:5439/mydatabase"
+ driver = "com.amazon.redshift.jdbc.Driver"
+ user = "myUser"
+ password = "myPassword"
+
+ generate_sink_sql = true
+ schema = "public"
+ table = "sink_table"
+ }
+}
+```
+
+### CDC(更改数据捕获) 事件
+
+> 我们也支持CDC更改数据。在这种情况下，您需要配置数据库、表和主键.
+
+```
+sink {
+ jdbc {
+ url = "jdbc:redshift://localhost:5439/mydatabase"
+ driver = "com.amazon.redshift.jdbc.Driver"
+ user = "myUser"
+ password = "mypassword"
+
+ generate_sink_sql = true
+ schema = "public"
+ table = "sink_table"
+
+ # config update/delete primary keys
+ primary_keys = ["id","name"]
+ }
+}
+```
+
diff --git a/docs/zh/connector-v2/sink/Sentry.md
b/docs/zh/connector-v2/sink/Sentry.md
new file mode 100644
index 0000000000..7f9c0236fe
--- /dev/null
+++ b/docs/zh/connector-v2/sink/Sentry.md
@@ -0,0 +1,78 @@
+# Sentry
+
+## 描述
+
+给哨兵写入消息.
+
+## 关键特性
+
+- [ ] [精确一次](../../concept/connector-v2-features.md)
+
+## 选项
+
+| 名称 | 类型 | 必需 | 默认值 |
+|-----------------------------|---------|----|---------------|
+| dsn | string | 是 | - |
+| env | string | 否 | - |
+| release | string | 否 | - |
+| cacheDirPath | string | 否 | - |
+| enableExternalConfiguration | boolean | 否 | - |
+| maxCacheItems | number | 否 | - |
+| flushTimeoutMills | number | 否 | - |
+| maxQueueSize | number | 否 | - |
+| common-options | | 否 | - |
+
+### dsn [string]
+
+DSN告诉SDK将事件发送到何处.
+
+### env [string]
+
+指定环境
+
+### release [string]
+
+指定版本
+
+### cacheDirPath [string]
+
+缓存脱机事件的缓存目录路径
+
+### enableExternalConfiguration [boolean]
+
+如果启用了从外部源加载属性.
+
+### maxCacheItems [number]
+
+用于限制事件数量的最大缓存项默认值为30
+
+### flushTimeoutMillis [number]
+
+控制冲洗前等待的秒数。Sentry SDK缓存来自后台队列的事件，并为该队列提供一定数量的待处理事件。默认值为15000=15s
+
+### maxQueueSize [number]
+
+将事件/信封刷新到磁盘之前的最大队列大小
+
+### common options
+
+接收器插件常用参数，详见 [Sink 常见选项](../sink-common-options.md)
+
+## 示例
+
+```
+ Sentry {
+ dsn = "https://[email protected]:9999/6";
+ enableExternalConfiguration = true
+ maxCacheItems = 1000
+ env = prod
+ }
+
+```
+
+## 变更日志
+
+### 2.2.0-beta 2022-09-26
+
+- 添加 Sentry 接收器连接器
+
