[
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)
