How to make Paho Mqtt custom adapter

• Hardware Platform (Jetson / GPU) Jetson XNX
• DeepStream Version 5.1
• JetPack Version (valid for Jetson only) 4.5.1

I want to use the MQTT protocol to send data to an Eclipse Paho server (local machine not AWS or Azure).
Is there an implementation tutorial on how to write a custom adapter?
Should the old API be used or the new? nvds_msgapi vs nv_msgbroker.

This would need other users to share experience and suggestion. By default we demonstrate the functionality with kafka server in test5 sample. Please check document:
DeepStream Reference Application - deepstream-test5 app — DeepStream 5.1 Release documentation

If customization is required, please check source code of the plugins in


Please also refer to
Gst-nvmsgbroker — DeepStream 5.1 Release documentation