question Invalid upstream connection for MQTT in Nifi in Archives of Support Questions (Read Only)

Invalid upstream connection for MQTT in Nifi

Sanaz_janbakhsh — Wed, 20 Sep 2017 11:46:58 GMT

Hi,

I installed mosquitto on hdf and it is running now. Now i am trying to call publishMQTT and receive the messages from broker but it gives me "upstream connections is invalid because processor requires an upstream connection but currently has none".

Please note the i also open the firewall rules and can do telnet to the broker URL too.

Please find the attached processor config.

Thanks,

SJuntitled.png

Re: Invalid upstream connection for MQTT in Nifi

alim — Wed, 20 Sep 2017 21:36:32 GMT

Hi @Sanaz Janbakhsh,

PublishMQTT is a processor that requires an incoming relationship. Basically, something has to be coming in to it to publish to a broker. That is why you are getting the "upstream connections is invalid..." message.

It sounds like you need to use the ConsumeMQTT processor which receives messages from an MQTT broker.

If I am misunderstanding your use case, please post a screenshot of your flow if possible.

Re: Invalid upstream connection for MQTT in Nifi

Sanaz_janbakhsh — Thu, 21 Sep 2017 02:12:08 GMT

Hi Andrew,

I've tried consumeMQTT too but the clientId was the issue. Thanks for your help.

Re: Invalid upstream connection for MQTT in Nifi

maryem — Wed, 11 Mar 2020 12:41:02 GMT

what about "PostHttp" processor ?? it always showing me the error Upstream connection is invalid! any help please