How to use msgbroker plugin to send payload messages to mosquitto

Please provide complete information as applicable to your setup.

• Hardware Platform (Jetson / GPU) Xavier NX and Jetson NANO
• DeepStream Version 5.0
• JetPack Version (valid for Jetson only)
• TensorRT Version
• NVIDIA GPU Driver Version (valid for GPU only)
• Issue Type( questions, new requirements, bugs) new requirement
• How to reproduce the issue ? (This is for bugs. Including which sample app is using, the configuration files content, the command line used and other details for reproducing)
• Requirement details( This is for new requirement. Including the module name-for which plugin or for which sample application, the function description)

Hi,
Deepstream 5.0 msgbroker plugin supports sending messages to Azure(mqtt) IOThub, kafka and AMQP broker(rabbitmq). Could anyone suggest how to send messages to mosquitto via MQTT protocol? Thank you

Hey, have you checked Gst-nvmsgbroker — DeepStream DeepStream Version: 5.0 documentation

Yes, checked. But nvmsgbroker only support mqtt to Azure.

Hi,
We do not support mosquitto broker, you can use interface, nvds_msgapi , to implement a custom protocol message handler and integrate it with DeepStream applications.
refer to this, Gst-nvmsgbroker — DeepStream DeepStream Version: 5.0 documentation

1 Like

Hi,
I can not find deepstream 5.0 msgapi so lib, and those so libs export nvds_msgapi_connect symbol are azure, amqp, kafka libs. Should I use libnvds_azure_proto.so? Thank you.

You can not use any library implemented using API nvds_msgapi for azure, amqp, kafka, you need to implement yourself if you want to use mosquitto, please see above comment 5.

Thank you & noted.

Hello,
AWS provided IoT Core Integration with NVIDIA DeepStream as below URL.

However, AWS MQTT client is based on TLS with x.509 certificate to make MQTT connection with server. Is there any way to make MQTT clients connect to the mosquitto server port 1883 for plaintext communication?
Thank you.

Please check mosquitto tutorial for details of implementation.