r/MQTT

Hey all,

I’ve been working on a lightweight tool called mqtt2otel and thought it might be useful for some of you here.

It basically connects MQTT-based IoT setups with the OpenTelemetry ecosystem. It subscribes to MQTT topics, lets you process/enrich the messages, and then exports them as OTel metrics/logs.

Why I built it:

• MQTT is great for IoT, but doesn’t integrate nicely with modern observability stacks, especially for logs, or even traces.
• Direct solutions to consume, parse, process and enrich mqtt messages in the dashboard system are often limited and have a high dependency to these systems making it hard to change later.
• OpenTelemetry is everywhere now, but not really designed for IoT ingestion
• Many architectures are allready build upon the OpenTelemetry stack, which gives you a nice abstraction for the different available Dashboard tools.

So this bridges the gap.

What it does:

• Subscribe to MQTT topics
• Transform / enrich messages (add metadata like location, device info, etc.)
• Export as OpenTelemetry metrics or logs

Would love to get feedback or ideas 🙌

Web: https://mqtt2otel.org GitHub: https://github.com/OSgAgA/mqtt2otel