MQTT MCP Server

An MCP (Model Context Protocol) server that enables Cursor to read messages from an MQTT broker.

Features

• Subscribe to MQTT topics (supports wildcards + and #)

• Read buffered messages from subscribed topics

• List active subscriptions

• Configurable message buffer size

Related MCP server: OMNI-MQTT-MCP

Installation

1. Install dependencies:

npm install

2. Build the project:

npm run build

3. Copy .env.example to .env and configure your MQTT broker settings:

cp .env.example .env

Configuration

Edit the .env file with your MQTT broker details:

Cursor Configuration

Add this MCP server to your Cursor settings (.cursor/mcp.json or global settings):

{
  "mcpServers": {
    "mqtt": {
      "command": "node",
      "args": ["C:/path/to/mqtt-mcp/dist/index.js"],
      "env": {
        "MQTT_BROKER_URL": "mqtt://your-broker:1883",
        "MQTT_USERNAME": "your_username",
        "MQTT_PASSWORD": "your_password"
      }
    }
  }
}

Alternatively, if using a .env file in the project directory:

{
  "mcpServers": {
    "mqtt": {
      "command": "node",
      "args": ["C:/path/to/mqtt-mcp/dist/index.js"],
      "cwd": "C:/path/to/mqtt-mcp"
    }
  }
}

Available Tools

mqtt_subscribe

Subscribe to an MQTT topic to start receiving messages.

Parameters:

• topic (required): The MQTT topic to subscribe to

• qos (optional): Quality of Service level (0, 1, or 2). Default: 0

Example:

Subscribe to "sensors/temperature"
Subscribe to "devices/+/status" (single-level wildcard)
Subscribe to "home/#" (multi-level wildcard)

mqtt_unsubscribe

Unsubscribe from an MQTT topic.

Parameters:

• topic (required): The MQTT topic to unsubscribe from

mqtt_read_messages

Read buffered messages from subscribed topics.

Parameters:

• topic (optional): Specific topic to read from. If omitted, reads from all topics

• limit (optional): Maximum messages to return. Default: 10

• clear (optional): Clear buffer after reading. Default: false

mqtt_list_subscriptions

List all active subscriptions and their message counts.

Parameters: None

Usage Example

1. First, subscribe to a topic:

   "Subscribe to the MQTT topic sensors/temperature"

2. Wait for messages to arrive, then read them:

   "Read the latest messages from sensors/temperature"

3. Check all active subscriptions:

   "List my MQTT subscriptions"

4. Unsubscribe when done:

   "Unsubscribe from sensors/temperature"

License

MIT