MCP Server Demo

基本能力

产品定位

a2a-mcp-server 是一个生产级的任务管理系统，旨在通过 MCP 和 Kafka 实现高效的任务管理和实时事件处理。

核心功能

• 任务管理：创建、更新、优先处理和完成任务。
• 通知系统：支持实时通知，并具有优先级级别。
• Kafka 集成：可靠的消息队列和事件流处理。
• MCP 工具：为 AI 代理提供友好的任务和通知操作接口。
• 消费者服务：后台处理 Kafka 消息。

适用场景

• 生产任务管理：适用于需要高效任务管理的生产环境。
• 实时事件处理：适用于需要实时处理事件的场景。
• AI 代理交互：适用于 AI 代理与任务队列交互的场景。

工具列表

任务管理

• fetch_queue：获取待处理任务列表。
• change_task_priority：更新任务优先级。
• pickup_task：标记任务为进行中。
• complete_task：标记任务为已完成。
• get_task_details：获取任务的详细信息。
• check_task_status：检查任务的当前状态。

通知管理

• check_notification_count：获取未读通知的数量。
• get_notification_list：获取过滤后的通知列表。
• mark_notification_as_read：标记通知为已读。

常见问题解答

• 如何配置 Kafka？：更新 kafka_config.py 文件中的 Kafka 集群详细信息。
• 如何启动服务器？：运行 python main.py。
• 如何加载测试数据？：运行 python kafka_test_data.py。

使用教程

使用依赖

• Python 3.13+
• Kafka 集群（本地或 AWS MSK）
• Confluent Kafka Python 客户端

安装教程

# 克隆仓库
git clone https://github.com/yourusername/mcp-server-demo.git
cd mcp-server-demo

# 安装依赖
pip install -e .

调试方式

1. 启动服务器：

python main.py

1. 加载测试数据：

python kafka_test_data.py

许可证

该项目遵循 MIT 开源许可条款。