SuperAPI AI 工具集

kafka-schema-registry

数据与分析

查看项目

更新于 10-15 23:46

技能介绍

用途:扫描项目识别 Kafka 生产者与消费者,从数据模型推断并提取 schema,生成用于 Confluent Schema Registry 注册的 Terraform 配置,并输出分析报告。适用于为项目补充事件 schema、集成 Schema Registry、审计 Kafka 生产/消费配置等场景。

主要能力:检测构建文件与 Kafka 依赖(如 spring-kafka、confluent-kafka、kafkajs),定位生产者与消费者、主题名与序列化器,建立应用目录;识别 auto.register.schemas=true、自定义序列化器等风险;从 Java 类、Pydantic 模型、TypeScript 接口、Go 结构体或内联数据推断 Avro、JSON Schema、Protobuf schema;按字段名标记 PII 并添加 confluent:tags;将生产者分类为 A 至 E 类;生成 schema 文件、Terraform 配置与 schema-report.md。

使用方式:调用该技能后,按阶段执行:初始化、项目扫描与 Kafka 检测、风险检测、schema 推断、生产者分类、创建 schema 文件、生成 Terraform、生成报告。输出位于项目根目录:schema-report.md、schemas/(含 avro、json、proto 子目录与 schema.yaml)、terraform/(providers.tf、variables.tf、tags.tf、schemas.tf、flagged-auto-register.tf、outputs.tf、import.sh)。schema 文件命名使用 kebab-case,如 order-events-value.avsc。若可用,调用 schema_lint(path: schemas/, fix: true) 校验。

限制:资料未提供具体收费、价格、平台支持范围与效果数据;Terraform 使用 Confluent provider,Category C 的 flagged-auto-register.tf 必须注释掉;无主题名时使用带 TODO 的占位符;测试目录默认跳过。