Peter Turcsanyi created NIFI-10894:
--------------------------------------
Summary: Resume Session in ConsumeMQTT does not work after NiFi
restart
Key: NIFI-10894
URL: https://issues.apache.org/jira/browse/NIFI-10894
Project: Apache NiFi
Issue Type: Bug
Reporter: Peter Turcsanyi
ConsumeMQTT in Resume Session mode should process the messages sent to broker
while the processor was offline after starting the processor again.
Using v5.0 specification version, it works if the processor is stopped and then
started but the "offline" messages get lost if the NiFi instance is restarted.
It seems the issue is that the async client needs to be used for connecting the
consumer (not only for the subscribe() call).
[https://github.com/apache/nifi/blob/830a64b8e95c1ff2baaa3b47234a5ba6c9a5d0de/nifi-nar-bundles/nifi-mqtt-bundle/nifi-mqtt-processors/src/main/java/org/apache/nifi/processors/mqtt/adapters/HiveMqV5ClientAdapter.java#L99]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
