davidzollo commented on code in PR #8834: URL: https://github.com/apache/seatunnel/pull/8834#discussion_r1970984194
########## docs/zh/connector-v2/sink/RocketMQ.md: ########## @@ -0,0 +1,202 @@ +# RocketMQ + +> RocketMQ sink 连接器 + +## 支持Apache RocketMQ版本 + +- 4.9.0 (或更新版本,供参考) + +## 支持这些引擎 + +> Spark<br/> +> Flink<br/> +> SeaTunnel Zeta<br/> + +## 主要特性 + +- [x] [精确一次](../../concept/connector-v2-features.md) + +默认情况下,我们将使用2pc来保证消息精确一次到RocketMQ。 + +## 描述 + +将数据行写入Apache RocketMQ主题。 + +## Sink 参数 + +| 名称 | 类型 | 是否必填 | 默认值 | 描述 | +|----------------------|---------|----------|--------------------------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------| +| topic | string | 是 | - | `RocketMQ topic` 名称. | +| name.srv.addr | string | 是 | - | `RocketMQ`名称服务器集群地址。 | +| acl.enabled | Boolean | 否 | false | false | +| access.key | String | 否 | | 当ACL_ENABLED为true时,access key不能为空。 | +| secret.key | String | 否 | | 当ACL_ENABLED为true时, secret key 不能为空。 | +| producer.group | String | 否 | SeaTunnel-producer-Group | SeaTunnel-producer-Group | +| tag | String | 否 | - | `RocketMQ`消息标签。 | +| partition.key.fields | array | 否 | - | - | +| format | String | 否 | json | 数据格式。默认格式为json。可选text格式。默认字段分隔符为“,”。如果自定义分隔符,请添加“field_delimiter”选项。 | +| field.delimiter | String | 否 | , | 自定义数据格式的字段分隔符。 | +| producer.send.sync | Boolean | 否 | false | 如果为 true, 则消息将同步发送。 | +| common-options | config | 否 | - | Sink插件常用参数,请参考[Sink common Options](../Sink-common-Options.md)了解详细信息。 | Review Comment: ```suggestion | common-options | config | 否 | - | Sink插件常用参数,请参考[Sink common Options](../sink-common-options.md)了解详细信息。 | ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@seatunnel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org