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://blog.csdn.net/github_35631540/article/details/130746029
版权归原作者 拿我格子衫来 所有， 如有侵权，请联系我们删除。
版权归原作者 拿我格子衫来 所有， 如有侵权，请联系我们删除。