forked from lf-edge/ekuiper
-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix(kafka): fix typo in kafka.json (lf-edge#2785)
Signed-off-by: L-607 <i@1l.fit>
- Loading branch information
Showing
1 changed file
with
235 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,235 @@ | ||
| { | ||
| "about": { | ||
| "trial": true, | ||
| "author": { | ||
| "name": "carlclone", | ||
| "email": "carlclone@gmail.com", | ||
| "company": "personal", | ||
| "website": "https://www.github.com/carlclone" | ||
| }, | ||
| "helpUrl": { | ||
| "en_US": "https://ekuiper.org/docs/en/latest/guide/sinks/plugin/kafka.html", | ||
| "zh_CN": "https://ekuiper.org/docs/zh/latest/guide/sinks/plugin/kafka.html" | ||
| }, | ||
| "description": { | ||
| "en_US": "This a sink for Kafka, it can be used for saving the analysis data into Kafka.", | ||
| "zh_CN": "为 Kafka 的持久化插件，可以用于将分析数据存入 Kafka 中" | ||
| } | ||
| }, | ||
| "libs": [ | ||
| "github.com/segmentio/kafka-go@v0.4.39" | ||
| ], | ||
| "properties": [ | ||
| { | ||
| "name": "brokers", | ||
| "default": "127.0.0.1:9092,127.0.0.2:9092", | ||
| "optional": false, | ||
| "control": "text", | ||
| "type": "string", | ||
| "hint": { | ||
| "en_US": "The url of the Kafka broker list", | ||
| "zh_CN": "Kafka brokers 的 URL 列表" | ||
| }, | ||
| "label": { | ||
| "en_US": "broker list", | ||
| "zh_CN": "Broker URL 列表" | ||
| } | ||
| }, | ||
| { | ||
| "name": "topic", | ||
| "default": "", | ||
| "optional": false, | ||
| "control": "text", | ||
| "type": "string", | ||
| "hint": { | ||
| "en_US": "The topic to publish to.", | ||
| "zh_CN": "订阅主题" | ||
| }, | ||
| "label": { | ||
| "en_US": "Topic", | ||
| "zh_CN": "主题" | ||
| } | ||
| }, | ||
| { | ||
| "name": "saslAuthType", | ||
| "default": "none", | ||
| "optional": false, | ||
| "control": "select", | ||
| "values": [ | ||
| "none", | ||
| "plain", | ||
| "scram" | ||
| ], | ||
| "type": "string", | ||
| "hint": { | ||
| "en_US": "Sasl auth type of Kafka", | ||
| "zh_CN": "Kafka 的 Sasl 认证类型" | ||
| }, | ||
| "label": { | ||
| "en_US": "Sasl auth type", | ||
| "zh_CN": "Sasl 认证类型" | ||
| } | ||
| }, | ||
| { | ||
| "name": "saslUserName", | ||
| "default": "", | ||
| "optional": true, | ||
| "control": "text", | ||
| "type": "string", | ||
| "hint": { | ||
| "en_US": "Sasl username for authentication", | ||
| "zh_CN": "Sasl 认证使用的用户名" | ||
| }, | ||
| "label": { | ||
| "en_US": "Sasl username", | ||
| "zh_CN": "Sasl 用户名" | ||
| } | ||
| }, | ||
| { | ||
| "name": "saslPassword", | ||
| "default": "", | ||
| "optional": true, | ||
| "control": "text", | ||
| "type": "string", | ||
| "hint": { | ||
| "en_US": "Sasl password for authentication", | ||
| "zh_CN": "Sasl 认证使用的密码" | ||
| }, | ||
| "label": { | ||
| "en_US": "Sasl password", | ||
| "zh_CN": "Sasl 密码" | ||
| } | ||
| }, | ||
| { | ||
| "name": "certificationPath", | ||
| "default": "", | ||
| "optional": true, | ||
| "connection_related": true, | ||
| "control": "text", | ||
| "type": "string", | ||
| "hint": { | ||
| "en_US": "The location of certification path. It can be an absolute path, or a relative path.", | ||
| "zh_CN": "证书路径。可以为绝对路径，也可以为相对路径。如果指定的是相对路径，那么父目录为执行 server 命令的路径。" | ||
| }, | ||
| "label": { | ||
| "en_US": "Certification path", | ||
| "zh_CN": "证书路径" | ||
| } | ||
| }, | ||
| { | ||
| "name": "privateKeyPath", | ||
| "default": "", | ||
| "optional": true, | ||
| "connection_related": true, | ||
| "control": "text", | ||
| "type": "string", | ||
| "hint": { | ||
| "en_US": "The location of private key path. It can be an absolute path, or a relative path. ", | ||
| "zh_CN": "私钥路径。可以为绝对路径，也可以为相对路径。" | ||
| }, | ||
| "label": { | ||
| "en_US": "Private key path", | ||
| "zh_CN": "私钥路径" | ||
| } | ||
| }, | ||
| { | ||
| "name": "rootCaPath", | ||
| "default": "", | ||
| "optional": true, | ||
| "connection_related": true, | ||
| "control": "text", | ||
| "type": "string", | ||
| "hint": { | ||
| "en_US": "The location of root ca path. It can be an absolute path, or a relative path. ", | ||
| "zh_CN": "根证书路径，用以验证服务器证书。可以为绝对路径，也可以为相对路径。" | ||
| }, | ||
| "label": { | ||
| "en_US": "Root CA path", | ||
| "zh_CN": "根证书路径" | ||
| } | ||
| }, | ||
| { | ||
| "name": "insecureSkipVerify", | ||
| "default": true, | ||
| "optional": true, | ||
| "control": "radio", | ||
| "type": "bool", | ||
| "hint": { | ||
| "en_US": "Control if to skip the certification verification. If it is set to true, then skip certification verification; Otherwise, verify the certification.", | ||
| "zh_CN": "控制是否跳过证书认证。如果被设置为 true，那么跳过证书认证；否则进行证书验证。" | ||
| }, | ||
| "label": { | ||
| "en_US": "Skip Certification verification", | ||
| "zh_CN": "跳过证书验证" | ||
| } | ||
| }, | ||
| { | ||
| "name": "batchSize", | ||
| "default": 1, | ||
| "optional": true, | ||
| "control": "text", | ||
| "type": "int", | ||
| "hint": { | ||
| "en_US": "Limit on how many messages will be buffered before being sent to kafka in one request, default 1", | ||
| "zh_CN": "一次性向 kafka 发送批量消息的数量" | ||
| }, | ||
| "label": { | ||
| "en_US": "Batch Size", | ||
| "zh_CN": "批量消息发送" | ||
| } | ||
| }, | ||
| { | ||
| "name": "maxAttempts", | ||
| "default": 1, | ||
| "optional": true, | ||
| "control": "text", | ||
| "type": "int", | ||
| "hint": { | ||
| "en_US": "Limit on how many attempts will be made to deliver a message, default 1", | ||
| "zh_CN": "发送消息失败的重试次数" | ||
| }, | ||
| "label": { | ||
| "en_US": "Max Attempts", | ||
| "zh_CN": "消息发送重发次数" | ||
| } | ||
| }, | ||
| { | ||
| "name": "headers", | ||
| "default": {}, | ||
| "optional": true, | ||
| "control": "list", | ||
| "type": "object", | ||
| "hint": { | ||
| "en_US": "Message Headers", | ||
| "zh_CN": "Headers in Kafka Message" | ||
| }, | ||
| "label": { | ||
| "en_US": "Headers for the message", | ||
| "zh_CN": "Kafka 消息 Headers" | ||
| } | ||
| }, | ||
| { | ||
| "name": "key", | ||
| "default": "", | ||
| "optional": true, | ||
| "control": "text", | ||
| "type": "string", | ||
| "hint": { | ||
| "en_US": "Message Key", | ||
| "zh_CN": "Kafka Message Key" | ||
| }, | ||
| "label": { | ||
| "en_US": "key for the message", | ||
| "zh_CN": "Kafka 消息 Key" | ||
| } | ||
| } | ||
| ], | ||
| "node": { | ||
| "category": "sink", | ||
| "icon": "iconPath", | ||
| "label": { | ||
| "en": "Kafka", | ||
| "zh": "Kafka" | ||
| } | ||
| } | ||
| } |