NiFi MQTT 5

2 replies
2097 views
Translate All

Does Apache NiFi supports MQTT 5? If it does, how do i get the Response Topic?

Apache NiFi

cotopaul

Platinum ⭐️

@Adhitya,

I am not quite sure what you mean with response topic, but as far as I can tell, you need to use ConsumeMQTT in order to "ingest" data out of the MQTT brokers/topics. If you want to publish within the brokers/topics, you will have to use PublishMQTT.

In both cases, you will have to choose the MQTT Specification Version, where you will have to select something from the following options: v3 Auto, v3.1.1, v3.1.0 and v5.0.

See: https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-mqtt-nar/1.21.0/org.apache.nifi.processors.mqtt.ConsumeMQTT/

Translate

AdhityaAuthor

Silver ⭐️⭐️

Thank you for your response cotopaul. In MQTT 5 there is a feature for Request-Response, in that feature there is a field setting to determine the response topic (different from the actual topic). The response topic field represents the topics on which the responses from the receivers of the message are expected. I was wondering if maybe NiFi could get the response topic field value from the MQTT as an attribute

Translate

Sign up

Please use your Cloudera account.

Login to the community

Please use your Cloudera account.