Pulsar MCP 服务器（Java）

使用 Spring Boot 和 Spring AI MCP 服务器启动器实现的 Pulsar MCP 服务器。

特性

• Pulsar 管理工具：完成 Pulsar 的管理操作

  • 租户管理（列出、创建、更新、删除）
  • 命名空间管理
  • 主题管理
  • 中介管理
  • 集群管理
  • 函数管理

• Pulsar 客户端工具：消息生产和消费

  • 使用属性和键的消息生产
  • 使用各种订阅类型的消息消费

• 安全配置文件：

  • 只读模式（默认）
  • 写入模式（通过 --spring.profiles.active=write 启用）

• 特性标志：通过配置启用/禁用特定工具组

快速开始

先决条件

• Java 17+
• 运行中的 Apache Pulsar 集群
• Maven 3.6+

构建

mvn clean package -DskipTests