How to integrate with Fluvio via MQTT, NATS, AMQP...

[luander]

Hello!
So I have a program called Litmus Edge which I use to connect and gather data from several PLCs. In order to consume different measurements from that program I can create an integration which can be MQTT, NATS, AMQP and more. But that's outbound connection, meaning I can tell Litmus Edge to connect to a MQTT broker and publish to a certain topic.

Is there a way to achieve that in Fluvio or I would need to write a small MQTT broker that forwards messages to Fluvio?

The flow would be something like:

LE -> MQTT -> Fluvio

[sehz]

Hi,

Yes, you can use MQTT to send information to fluvio. Alternatively, you can use Mirroring that will transparent replicate edge from to core cluster.

[drc-infinyon]

Hey @luander Thanks for the question.

There are a couple of ways to do it. You have already got one.

Fluvio has a MQTT connector which can get data from MQTT if you are running a MQTT broker like mosquito. Here is an example in the docs on that.

MQTT Connector - https://www.fluvio.io/docs/hub/connectors/inbound/mqtt
MQTT to SQL Tutorial - https://www.fluvio.io/docs/cloud/tutorials/mqtt-to-sql

Now the second way works if you have some compute and storage available on the device communicating with the PLC.
Fluvio runs on edge devices like raspberry pi and can get data directly using the producer of the fluvio client.

Here is some docs on that:
Mirroring RaspberryPi to Fluvio Cluster - https://www.fluvio.io/docs/fluvio/tutorials/mirroring-iot-local
Mirroring Fluvio Cluster to Fluvio Cluster - https://www.fluvio.io/docs/fluvio/tutorials/mirroring-two-clusters