Best MQTT MCP Servers
MQTT is a lightweight messaging protocol for IoT devices that enables efficient communication in low-bandwidth, high-latency, or unreliable networks. It uses a publish/subscribe model and is designed for constrained devices and networks.
Why this server?
Provides local, offline validation of MQTT topic strings against the Sparkplug B topic grammar and checks Unified Namespace topic paths for naming consistency issues such as inconsistent depth, mixed casing, duplicates, empty levels, and stray wildcards. It does not connect to an MQTT broker.
AlicenseAqualityAmaintenanceFree Industry 4.0 / IIoT tools, no API key or account: lint MQTT Sparkplug B topics, check a Unified Namespace (UNS) for naming and hierarchy problems, and run an industrial AI-readiness diagnostic for manufacturing digital transformation and smart-factory projects. Works in Claude Code, Codex and any MCP client.3290 npmMITWhy this server?
Allows the architecture agent to propose adding an MQTT connector to a record, so an AimDB topology can be wired up to MQTT topics as part of a proposed (and later confirmed) architecture change.
Why this server?
Allows monitoring MQTT broker connectivity as a check type.
AlicenseAqualityAmaintenanceUptime monitoring from your AI agent: create and diagnose checks (40 types: HTTP, TCP, DNS, SSL, ICMP, databases, message queues and more), read results and incidents, and manage status pages and maintenance windows. Built into the self-hostable SolidPing server, served over streamable HTTP at /api/v1/mcp.2322AGPL 3.0Why this server?
Interacts with MQTT brokers and Sparkplug B payloads. Supports reading topic values, bounded subscriptions, node discovery, and UNS (Unified Namespace) browsing. Publish operations are high-risk and require MOC approval.
AlicenseAqualityAmaintenanceProvides AI agents with safe, governed read access to industrial control systems (OPC-UA, Modbus, S7, Mitsubishi, MTConnect, MQTT/Sparkplug) plus cross-protocol diagnostics for troubleshooting data breaks, alarm floods, and unhealthy tags.1557MITWhy this server?
Allows subscribing to MQTT topics, reading buffered messages, unsubscribing, and listing active subscriptions via an MQTT broker.
AlicenseAqualityDmaintenanceEnables Cursor to subscribe to MQTT topics and read buffered messages from an MQTT broker.517 npmISCWhy this server?
Allows publishing messages to an MQTT broker via the publish_message tool, enabling agents to send notifications or data to MQTT topics.
Why this server?
Supports monitoring and debugging of the MQTT integration within Home Assistant, enabling searches for related entities and access to integration-specific debug logs.
AlicenseAqualityCmaintenanceEnhanced Home Assistant MCP server with 22 context efficient tools for smart home control, automation trace debugging, entity registry management, CEL expression queries, and long-term statistics.223MITWhy this server?
Provides an adapter for reading timestamped events from MQTT topics, allowing agents to correlate physical camera frames and timeline data with MQTT event streams.
AlicenseAqualityAmaintenanceEnables AI agents to perceive and quantitatively verify physical hardware through USB webcams and RTSP/HTTP network streams, returning inline image content plus numerical metrics such as brightness, contrast, edge density, motion, SSIM baseline comparisons, and OCR text. Agents can watch feeds for visual conditions, correlate buffered frames with serial/log/MQTT events, and apply privacy masks and access controls.1941 PyPIMITWhy this server?
Allows interaction with MQTT clusters on EMQX Cloud or self-hosted clusters, enabling clients to list connected MQTT clients, retrieve client information, disconnect clients, and publish messages to MQTT topics
AlicenseBqualityDmaintenanceA Model Context Protocol (MCP) server implementation that provides EMQX MQTT broker interaction.426Apache 2.0