IoT: Using MiniFi Java Agent to Send MQTT Messages from Devices Example NVidia Jetson TX1 with Apache MXNet

[#1]

Using MQTT From MiniFi Java Agent

From a standard Apache NiFi 1.5 download.

Copy

• nifi-standard-services-api-nar-1.5.0.3.1.1.0-35.nar
• nifi-mqtt-nar-1.5.0.3.1.1.0-35.nar

To minifi 0.40. lib directory.

PublishMQTT

Publish Sensor Data Via MQTT

This is our example MiniFi flow. We can drop out the GetFile (to grab images) and push to NiFi Flow if we just want to do a simple MQTT use case.

I am using CloudMQTT, you can use any MQTT broker like Mosquitto or HiveMQ.

Ingest in Apache NiFi 1.5

We can process data from MQTT and/or standard Apache NiFi S2S HTTPS.

Processing continues as regular. I add another route for mqtt source.

References:

If you are doing SSL, see https://community.hortonworks.com/articles/47854/accessing-facebook-page-data-from-apache-nifi.html

[#2]

I am getting below error :2018-11-12 16:37:28,189 WARN [pool-2-thread-1] o.a.n.m.b.c.i.PullHttpChangeIngestor Hit an exception while trying to pull http://java.net.ConnectException: Failed to connect to /127.0.0.1:10080 Jira tkt for the same issuehttp://mail-archives.apache.org/mod_mbox/nifi-commits/201805.mbox/%3CJIRA.13157686.1525721467000.15178.1525721820467@Atlassian.JIRA%3E

How to resolve above issue.Please help.