1 Star 1 Fork 1

ThingsGateway/Docs

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
KafkaProducer.mdx 4.08 KB
一键复制 编辑 原始数据 按行查看 历史
Diego 提交于 3个月前 . 更新文档
---
id: 304
title: KafkaProducer
---
import useBaseUrl from "@docusaurus/useBaseUrl";
import Tag from "@site/src/components/Tag.js";
import Highlight from '@site/src/components/Highlight.js';
:::tip `提示`
通过自定义脚本,可快速适配业务模型
:::
:::tip `须知`
插件使用**librdkafka**,注意按需安装c库
On Mac OSX, install librdkafka with homebrew:
```
$ brew install librdkafka
```
On Debian and Ubuntu, install librdkafka from the Confluent APT repositories, see instructions here and then install librdkafka:
```
$ apt install librdkafka-dev
```
On RedHat, CentOS, Fedora, install librdkafka from the Confluent YUM repositories, instructions here and then install librdkafka:
```
$ yum install librdkafka-devel
```
For other platforms, follow the source building instructions below.
:::
## 一、说明
KafkaProducer适配Kafka协议,主动发布内容到服务端,可以定时/变化发布数据
通道只支持 Other
## 二、插件属性配置项
<img src={require("@site/static/img/docs/KafkaProducer1.png").default} />
| 属性 | 说明 | 备注|
| ---------------| --------------------------| ---|
| 服务地址 | 服务地址 | 127.0.0.1:9092|
| 发布超时时间 | 发布超时时间 |5000 |
| 用户名 | 用户名 | |
| 密码 | 密码 | |
| SecurityProtocol | SecurityProtocol | |
| SaslMechanism | SaslMechanism | |
| 分组上传 | 启用后,无论是定时还是变化模式,始终会上传**变量分组属性**为key分组的全部变量 。在变化模式时,每次变量变化都会触发一次组上传 | False |
| 选择全部变量 | 选择全部变量 | False |
| 设备状态列表上传 | 设备是否列表上传,false时每个设备实体都会单独发布,注意性能需求,默认为true | |
| 变量列表上传 | 变量是否列表上传,false时每个变量实体都会单独发布,注意性能需求,默认为true | |
| 报警列表上传 | 报警是否列表上传,false时每个报警实体都会单独发布,注意性能需求,默认为true | |
| 设备Topic | 设备实体的发布主题 ,使用``${key}``作为匹配项,key必须是上传实体中的属性 | |
| 变量Topic | 变量实体的发布主题 ,使用``${key}``作为匹配项,key必须是上传实体中的属性 | |
| 报警Topic | 报警实体的发布主题 ,使用``${key}``作为匹配项,key必须是上传实体中的属性 | |
| 设备实体脚本 | 脚本返回新的实体列表,动态类中需继承**IDynamicModel**,传入列表为**DeviceData**,查看以下具体属性 | 编辑页面中,可通过检查按钮验证脚本 |
| 变量实体脚本 | 脚本返回新的实体列表,动态类中需继承**IDynamicModel**,传入列表为**VariableBasicData**,查看以下具体属性 | 编辑页面中,可通过检查按钮验证脚本 |
| 报警实体脚本 | 脚本返回新的实体列表,动态类中需继承**IDynamicModel**,传入列表为**AlarmVariable**,查看以下具体属性 | 编辑页面中,可通过检查按钮验证脚本 |
| 选择全部变量 | 是否选择全部变量,true时不需要单个变量添加业务属性 | |
| 上传模式 | 间隔/变化/变化和间隔同时生效 | |
| 定时上传间隔 | 间隔执行时间 | |
| 启用缓存 | 是否启用缓存 | |
| 缓存文件最大长度(mb) | 缓存文件最大长度 | |
| 上传每页条数 | 每一次上传的列表最大数量 | |
| 内存队列最大数量 | 内存队列的最大数量,超出或失败时转入文件缓存,根据数据量设定适当值 | |
## 三、脚本与实体
查看MqttClient页面[脚本接口](./MqttClient.mdx#脚本接口)
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/ThingsGateway/Docs.git
git@gitee.com:ThingsGateway/Docs.git
ThingsGateway
Docs
Docs
master

搜索帮助