当前位置：首页 > news >正文

NIFI的处理器：ConsumeMQTT 2.4.0

news 来源：原创 2025/6/12 23:10:37

该处理器用于从MQTT Broker中订阅主题，并接收数据。

该处理器具有以下属性：
Broker URI: MQTT Broker地址，例如：tcp://127.0.0.1:1883;
MQTT Specificaton Version: MQTT版本，下拉选单，默认值是V3 AUTO, 还有v3.1.0, v3.1.1, v5.0;
Username: 用户名;
Password: 密码;
SSL Context Service: SSL上下文服务，支持SSL,TLS，支持文件上传;
Session state：是重新开始还是恢复之前的流程。这里用默认值Clean Session;
Topic Filter: 过滤器，用于过滤订阅的主题;
Quality of Service(QoS)：下拉选单，0是最多一次，1是至少一次，2是恰好一次;
Max Queue Size：指定了此处理器的单个实例在NiFi内存中可以保存的最大消息数。默认值是100，可根据实际情况修改成较大的值。

Record Reader：用于将接收到的MQTT消息解析为记录的记录读取器，默认值为空。
Record Writer：用于在将记录写入FlowFile之前对其进行序列化的记录写入器，默认值为空。

需要注意的时，当NIFI为集群时，可以将该处理器设置为只在主节点运行，否则，可能会出现重复消费的问题。