davidzollo commented on code in PR #8834: URL: https://github.com/apache/seatunnel/pull/8834#discussion_r1970984695
########## 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)了解详细信息。 | + +### partition.key.fields [array] + +配置哪些字段用作RocketMQ消息的键。 +例如,如果要使用上游数据中的字段值作为键,可以为此属性指定字段名。 +上游数据如下: + +| name | age | data | +|------|-----|---------------| +| Jack | 16 | data-example1 | +| Mary | 23 | data-example2 | + +如果name被设置为键,那么name列的哈希值将决定消息被发送到哪个分区。 Review Comment: ```suggestion 如果name被设置为主键,那么name列的哈希值将决定消息被发送到哪个分区。 ``` -- 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