Hi,

 

I’m working on to receive data published to mosquitto broker. For which I setup a pipeline to publish and consume message to the topic.

But I’m receiving error “Connection to tcp://localhost:1883 lost and reconnect failed”

 

PublishMQTT settings:

 

Broker URI : tcp://localhost:1883

Client ID : client1

Topic : demo/mqtt1

Retain message : true

Qos : 0

 

ConsumeMQTT settings :

 

Broker URI : tcp://localhost:1883

Client ID : client1

Topic : demo/mqtt1

Qos : 0

 

I’m able to publish and subscribe messages using command prompt.

Not sure what is the problem with Nifi. Please do guide me

 

FYI  : Nifi is not a cluster.It is a single node

 

Regards

Vyshali