Pulsar MCP服务器(Java)
使用Spring Boot和Spring AI MCP Server Boot Starter的Pulsar MCP Server的Java实现。
特性
- Pulsar管理工具:完成Pulsar管理操作
- 租户管理(列表、创建、更新、删除) - 命名空间管理 - 主题管理 - 经纪人管理 - 集群管理 - 功能管理
- Pulsar客户端工具:信息生产和消费
- 使用属性和密钥生成消息 - 各种订阅类型的消息消费
- 安全配置文件:
- 只读模式(默认) - 写入模式(通过--spring.profiles.active=Write启用)
- 功能标志:通过配置启用/禁用特定工具组
快速开始
先决条件
- Java 17+
- Apache Pulsar集群正在运行
- Maven 3.6+
构建
mvn clean package -DskipTests