用途:该技能用于通过 Membrane CLI 与 Confluent 平台交互,管理数据、记录并自动化工作流,适合需要操作 Confluent 数据的场景。
主要能力:可管理集群、Kafka 主题、Kafka 连接器、组织、环境、服务账号、用户与认证等资源。常见操作包括列出主题、集群、消费者组、代理、分区、ACL,获取主题/集群/消费者组/代理/分区详情,创建与删除主题、创建与删除 ACL、更新主题配置、更新主题分区数、列出主题配置与分区偏移量、向主题生产记录等。
使用方式:先安装 CLI:npm install -g @membranehq/cli@latest。登录:membrane login --tenant --clientName=<agentType>;无头环境会打印授权 URL,用户完成登录后用 membrane login complete <code> 收尾。连接 Confluent:membrane connection ensure "https://www.confluent.io/" --json,用户在浏览器完成认证;若状态为 BUILDING,用 npx @membranehq/cli connection get <id> --wait --json 轮询至 READY。搜索动作:membrane action list --connectionId=CONNECTION_ID --intent "QUERY" --limit 10 --json。运行动作:membrane action run <actionId> --connectionId=CONNECTION_ID --json,传参用 --input '{"key": "value"}'。当动作不覆盖需求时,可通过代理直接请求 Confluent API:membrane request CONNECTION_ID /path/to/endpoint,支持 -X/--method、-H/--header、-d/--data、--json、--rawData、--query、--pathParam 等选项。任意命令加 --json 可获得机器可读输出。
适用场景:需要以编程或代理方式查询与管理 Confluent Kafka 资源、生产记录、维护 ACL 与主题配置等集成任务。
限制:认证与凭据刷新由 Membrane 服务端处理,不应向用户索取 API key 或 token;具体可用动作与参数以实际返回的 inputSchema/outputSchema 为准。官方文档见 https://docs.confluent.io/。