Scans projects for Kafka usage, extracts schemas from data models, tags PII fields, generates Terraform for Confluent Schema Registry, and produces a migration report with rollout ordering.
How this skill is triggered — by the user, by Claude, or both
Slash command
/streaming-skills-plugin:kafka-schema-registryThe summary Claude sees in its skill listing — used to decide when to auto-load this skill
Scan a project to identify Kafka applications, extract schemas, generate Terraform for Schema Registry registration, and produce a comprehensive analysis report.
evals/evals.jsonevals/mock-repos/acme-services/billing-service/pom.xmlevals/mock-repos/acme-services/billing-service/src/main/java/com/acme/billing/Invoice.javaevals/mock-repos/acme-services/inventory-service/requirements.txtevals/mock-repos/acme-services/inventory-service/src/producer.pyevals/mock-repos/acme-services/reporting-service/src/consumer.pyevals/mock-repos/acme-services/user-service/pom.xmlevals/mock-repos/acme-services/user-service/src/main/java/com/acme/users/UserEvent.javaevals/mock-repos/api-gateway/package.jsonevals/mock-repos/api-gateway/src/middleware.jsevals/mock-repos/api-gateway/src/server.jsevals/mock-repos/ecommerce-platform/analytics-service/requirements.txtevals/mock-repos/ecommerce-platform/analytics-service/src/analytics_producer.pyevals/mock-repos/ecommerce-platform/notification-service/package.jsonevals/mock-repos/ecommerce-platform/notification-service/src/notification-producer.jsevals/mock-repos/ecommerce-platform/order-service/pom.xmlevals/mock-repos/ecommerce-platform/order-service/src/main/java/com/ecommerce/orders/OrderEvent.javaevals/mock-repos/ecommerce-platform/order-service/src/main/java/com/ecommerce/orders/OrderProducer.javaevals/mock-repos/go-kafka-producer/go.modevals/mock-repos/go-kafka-producer/producer.goScan a project to identify Kafka applications, extract schemas, generate Terraform for Schema Registry registration, and produce a comprehensive analysis report.
Invoke this skill when:
This skill produces 3 outputs in the target project:
schema-report.md — Full analysis report with findings, risks, and upgrade recommendationsschemas/ — Extracted schema files (Avro, JSON Schema, Protobuf) with PII taggingterraform/ — Terraform configs using Confluent provider to register schemasIf the user asks for their application code to be updated to integrate Schema Registry, use the Code Migration Reference to update the code with proper Schema Registry integration patterns.
schema.yaml and schemas/ directory manuallypom.xml, build.gradle, requirements.txt, package.json, etc.spring-kafka, confluent-kafka, kafkajs, etc.KafkaTemplate, Producer(, producer.send, etc.value.serializer, KafkaAvroSerializer, custom serializersDetailed patterns: Detection Patterns Reference
App catalog structure:
app_name: module name
language: Java | Python | .NET | Go | Node/TS
role: producer | consumer | both
topics: [list of topics]
serializer_class: value.serializer used
custom_serializer: true | false
schema_format: AVRO | JSON | PROTOBUF | UNKNOWN
sr_integrated: true | false
category: A | B | C | D | E # REQUIRED
Multi-schema topic detection:
oneOf/union/oneofschema_reference blocksSearch for:
auto.register.schemas=true — Uncontrolled schema evolution (Category C)use.latest.version — Eases migration when setRecord file path, line number, and affected topics for each occurrence.
Patterns: Detection Patterns Reference
For each producer:
**/*.avsc, **/*.proto, **/*.schema.jsonemail, ssn, phone, address, etc.PII tagging: Add confluent:tags (PII, PRIVATE, SENSITIVE, PHI) to detected fields.
Detailed inference patterns: Schema Inference Reference
Classify each producer:
| Category | Criteria |
|---|---|
| A: Compliant | Confluent serializer + SR + no auto.register |
| A→Header | Already on SR, migrating to headers |
| B: Schema in code, no SR | Data models exist, but no SR integration |
| C: Auto-register | auto.register.schemas=true |
| D: No schema | Raw strings/bytes, no data model |
| E: Custom serializer | Custom Serializer<T> or inline serialization without SR |
CRITICAL: Use exact phrase "Category X" in:
Details: Categorization Reference
Directory structure:
schemas/
├── avro/
│ └── {topic}-value.avsc
├── json/
│ └── {topic}-value.json
└── proto/
└── {topic}-value.proto
File naming: MUST use kebab-case (lowercase with hyphens):
{topic}-value.{ext}{topic}-key.{ext}order-events-value.avsc, user-notifications-value.jsonInitialize: Create schema.yaml.
Validate: Call schema_lint(path: schemas/, fix: true) if available.
File structure (MANDATORY separate files):
terraform/
├── providers.tf # Provider config
├── variables.tf # Variable definitions
├── tags.tf # confluent_tag resources (if PII exists)
├── schemas.tf # Active schemas (A, B, E)
├── flagged-auto-register.tf # Category C only (commented out)
├── outputs.tf # Output values
└── import.sh # Import script
CRITICAL:
schemas.tf = Categories A, B, E — NOT commented outflagged-auto-register.tf = Category C ONLY — MUST be commented outtags.tf = MUST exist if ANY schema uses confluent:tagsTemplates: Terraform Templates Reference
Create schema-report.md with:
CRITICAL formatting requirements:
Template: Report Template Reference
Details: Categorization Reference
{project_root}/
├── schema-report.md # Analysis report
├── schemas/
│ ├── schema.yaml # Schema project config
│ ├── avro/
│ │ └── {topic}-value.avsc
│ ├── json/
│ │ └── {topic}-value.json
│ └── proto/
│ └── {topic}-value.proto
└── terraform/
├── providers.tf
├── variables.tf
├── tags.tf # PII/PRIVATE/SENSITIVE tags
├── schemas.tf # Active schemas (depends_on tags)
├── flagged-auto-register.tf # Commented-out Category C
├── outputs.tf
└── import.sh # Import existing schemas
No need to use Agent tool — this skill is self-contained and uses direct tool calls.
npx claudepluginhub confluentinc/agent-skills --plugin streaming-skills-pluginReviews Kafka schema changes (Avro, Protobuf, JSON Schema) for compatibility and evolution best practices using the Lenses MCP server. Detects breaking changes, missing defaults, schema drift and naming issues.
Builds Python Kafka producers/consumers with confluent-kafka-python, adds Schema Registry, scaffolds projects for Confluent Cloud, local Docker, or WarpStream, and optimizes client config for WarpStream.
Creates and repairs Redpanda Connect pipeline configurations from natural language descriptions or broken configs. Delegates to component-search and bloblang-authoring skills.