@msgmesh/mcp-server

@msgmesh/mcp-server

讓 AI agent 原生訂閱事件流的 MCP server。

MsgMesh 是架在 Kafka 之上的多租戶事件總線。把這個 MCP server 加進 Claude Desktop / Cursor,agent 就能用自然語言收發事件、監看 topic、甚至自己開通金鑰—— 你不必為它寫一層事件橋。

「監看 orders 這個 topic,有新訂單就告訴我。」

agent 會呼叫 watch_topic 長輪詢等下一批事件,收到就處理、再繼續等。

設定

加進 Claude Desktop(claude_desktop_config.json)或 Cursor 的 MCP 設定:

{
  "mcpServers": {
    "msgmesh": {
      "command": "npx",
      "args": ["-y", "@msgmesh/mcp-server"],
      "env": {
        "MQ_API_KEY": "<你的 API Key>",
        "MQ_CONTROL_PLANE_URL": "https://msgapi.jason3c.com",
        "MQ_GATEWAY_URL": "https://msgapi.jason3c.com"
      }
    }
  }
}

不需要事先安裝:npx -y 會在首次啟動時自動取得。

還沒有 API Key?

面板註冊後可簽發一把。或者——直接讓 agent 自己開通:

「用 create_key 建一把能 publish + subscribe 的 key,然後監看 support.tickets。」

agent 有 create_key / create_topic / watch_topic,會自我 bootstrap 後開始監看。 (自助開通需要一把有 admin scope 的 key;完全沒有 key 時請先到面板簽發。)

環境變數

變數	說明
MQ_API_KEY	API Key(必要)。
MQ_CONTROL_PLANE_URL	管理 API(建 topic / 簽 key / 查用量)。
MQ_GATEWAY_URL	收發 API(publish / consume)。

工具

29 個 tool,涵蓋:

• 收發:publish_message、consume_messages、watch_topic(長輪詢等下一批事件—— 「watch → 反應 → 再 watch」的核心)、get_presence
• Topic:create_topic、list_topics、delete_topic
• 金鑰:create_key(支援 capabilities 細粒度能力)、list_keys、delete_key
• Schema:register_schema、get_schema、list_schemas、delete_schema
• Webhook:create_webhook、list_webhooks、delete_webhook
• 函數:register_function、get_function、delete_function
• 死信:dlq_peek、dlq_replay
• 其他:get_usage、get_audit、get_plan、set_plan、get_billing、 get_connection_snippet、get_docs

相關

• API 參考(可線上試打):https://msgapi.jason3c.com/docs
• TypeScript SDK:@msgmesh/sdk

授權

MIT