用途:帮助把自建 Apache Kafka(本地、EC2、Docker、Kubernetes 等非 MSK 部署)迁移到 Amazon MSK Express。从 MSK Standard(Provisioned)迁移不在范围内。
主要能力:分两个可独立运行的阶段。阶段一 Discovery 盘点源集群的 broker、topic、分区数、配置、认证与负载指标,输入可为 IaC 文件(Terraform、CDK、Docker Compose、Kubernetes manifest)、客户在集群上运行的 Kafka CLI 输出或手工提供的信息,输出 migrate-to-msk-skill-artifacts/<cluster_name>/cluster-config.json。阶段二 Assessment 依据该文件做五支柱兼容性评估(拓扑、Kafka 版本、配置、认证、配额),输出 compatibility.<cluster_name>.json、填好的 MSK_Sizing_Pricing.<cluster_name>.xlsx 与 msk-sizing-inputs.<cluster_name>.json。评估脚本为纯文件处理器,无 AWS API 调用。
使用方式:Discovery 前必须先读 references/discovery.md 并按其模板与 JSON schema 执行;评估通过 uv run 运行 scripts/compatibility.py 与 scripts/sizing.py(PEP 723 内联依赖),sizing.py 需传入 agent 下载的 AWS 工作簿,命令为 sizing.py --workbook <downloaded.xlsx>。数据复制可参考 MSK Replicator。
适用场景:自建 Kafka 迁移前的现状盘点、兼容性核查与目标规格/成本测算。
限制:不覆盖 MSK Standard 到 Express 的迁移;评估不回头补做发现,缺失字段以 ADVISORY 证据呈现;工作簿需打开后公式重算才显示 broker 数与成本;AWS MCP 服务器为推荐而非必需。安全上要求 TLS 传输加密、KMS 静态加密、优先 IAM 认证、凭据存 Secrets Manager、私有子网部署,输出含敏感信息需脱敏。