Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Invalid upstream connection for MQTT in Nifi

Solved Go to solution
Highlighted

Invalid upstream connection for MQTT in Nifi

Rising Star

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

1 ACCEPTED SOLUTION

Accepted Solutions
Highlighted

Re: Invalid upstream connection for MQTT in Nifi

Guru

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.

View solution in original post

3 REPLIES 3
Highlighted

Re: Invalid upstream connection for MQTT in Nifi

Guru

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.

View solution in original post

Highlighted

Re: Invalid upstream connection for MQTT in Nifi

New Contributor

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

Highlighted

Re: Invalid upstream connection for MQTT in Nifi

Rising Star

Hi Andrew,

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

SJ

Don't have an account?
Coming from Hortonworks? Activate your account here