Support Questions
Find answers, ask questions, and share your expertise

MiNiFi : Error in publishing the message to mqtt

New Contributor

I am using mqtt box to publish the message on Topic A and then it is suscribed in and consume in MiNiFi. After that the same message is sent to a directory using putfile processor and then the publisher use that message and piblish it on a Topic B. Suscriber in the mqtt box is suscribed to Topic B. But I have the error while piblishing the message on Topic B. Below is the error in the MiNiFi log::

 

WARN [MQTT Rec: 9304a3a5-938f-4089-a878-8cb5219d66d6] o.a.nifi.processors.mqtt.PublishMQTT PublishMQTT[id=7199a21d-7af7-3e5e-0000-000000000000] Connection to tcp://localhost:1883 lost
org.eclipse.paho.client.mqttv3.MqttException: Connection lost
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:181)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.io.EOFException: null
at java.io.DataInputStream.readByte(DataInputStream.java:267)
at org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:133)
... 7 common frames omitted
2019-11-04 20:02:56,280 ERROR [MQTT Rec: 9304a3a5-938f-4089-a878-8cb5219d66d6] o.a.nifi.processors.mqtt.PublishMQTT PublishMQTT[id=7199a21d-7af7-3e5e-0000-000000000000] Connection to tcp://localhost:1883 lost and re-connect failedCapture1.PNGCapture2.PNG

0 REPLIES 0