Uploaded image for project: 'Apache NiFi'
  1. Apache NiFi
  2. NIFI-10894

Resume Session in ConsumeMQTT does not work after NiFi restart

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.18.0, 1.19.0
    • None
    • Extensions
    • None

    Description

      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

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              turcsanyip Peter Turcsanyi
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: