Bryan Rosander created NIFI-2045:
------------------------------------
Summary: ConsumeMQTT can lose a message if session commit fails
Key: NIFI-2045
URL: https://issues.apache.org/jira/browse/NIFI-2045
Project: Apache NiFi
Issue Type: Bug
Affects Versions: 1.0.0
Reporter: Bryan Rosander
Priority: Critical
ConsumeMQTT removes the received message from the queue before committing the
session. This means that if the session commit fails and the session rolls
back, the message will be lost.
https://github.com/apache/nifi/blob/f47af1ce8336c9305916f00738976f3505b01b0b/nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/ConsumeMQTT.java#L292
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
