Kafka Node
Since TB Version 2.0
Kafka节点将消息发送到Kafka代理。它可以接收任何类型的消息。该节点会通过Kafka生产者将记录发送到Kafka服务器。
配置
- 主题模式 - 可以是静态字符串，也可以是使用消息元数据属性解析的模式。例如${deviceType}
- 引导服务器 - 用逗号分隔的kafka代理列表。
- 自动重试次数 - 如果连接失败，重新发送消息的尝试次数。
- 生成批量大小 - 用于将具有相同分区的消息分组的批量大小（按字节计）。
- 本地缓冲时间 - 最大本地缓冲窗口持续时间(单位: 毫秒)。
- 客户端缓冲最大大小 - 用于发送消息的最大缓冲区大小(按字节计)。
- 确认数量 - 节点在考虑请求完成之前需要接收的确认数量。
- 键序列化器 - 默认为org.apache.kafka.common.serialization.StringSerializer
- 值序列化器 - 默认为org.apache.kafka.common.serialization.StringSerializer
- 其他属性 - 可提供任何其他附加属性以进行与kafka代理的连接。
发布的正文 - 节点将完整的消息负载发送到Kafka主题。如果需要，规则链可配置为使用转换节点链以正确发送有效负载到Kafka。文章来源：https://www.toymoban.com/news/detail-649124.html
此节点的出站消息将在消息元数据中包含响应偏移量、分区和主题属性。原始消息负载、类型文章来源地址https://www.toymoban.com/news/detail-649124.html
到了这里，关于ThingsBoard教程（五三）：规则节点解析 Kafka Node， MQTT Node的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
