You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@nifi.apache.org by "Peter Turcsanyi (Jira)" <ji...@apache.org> on 2022/03/22 17:11:00 UTC

[jira] [Commented] (NIFI-9821) ConsumeMQTT write attribute for message identifier

    [ https://issues.apache.org/jira/browse/NIFI-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510762#comment-17510762 ] 

Peter Turcsanyi commented on NIFI-9821:
---------------------------------------

[~cannonpalms]  According to ConsumeMQTT's documentation (and its code), the processor writes attribute: mqtt.qos - The quality of service for this message.
Doesn't it work for you?

> ConsumeMQTT write attribute for message identifier
> --------------------------------------------------
>
>                 Key: NIFI-9821
>                 URL: https://issues.apache.org/jira/browse/NIFI-9821
>             Project: Apache NiFi
>          Issue Type: Improvement
>            Reporter: Cannon Palms
>            Priority: Major
>
> MQTT messages can have identifiers set on them by the publishing client for QoS 1-2. This property is useful for a variety of purposes, e.g. handling duplicate messages received by running the ConsumeMQTT processor on all nodes. The eclipse paho library currently in use already supports this field. We just need to add support for writing this value as an attribute, similar to the existing attributes that can optionally be written by the processor.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)