Extracts and transforms Avro, Protobuf, and JSON Schema definitions from Confluent Schema Registry. Generates typed data models and validates schema compatibility using the Schema Registry REST API.
Installs into .claude/skills of the current project.
Are you the author of Apache Kafka Schema Extractor?
Add the live security badge to your README. It updates with every re-scan.
[](https://www.skillsdirectory.com/skills/agentskillexchange-apache-kafka-schema-extractor)
---
name: "Apache Kafka Schema Extractor"
slug: "apache-kafka-schema-extractor"
description: "Extracts and transforms Avro, Protobuf, and JSON Schema definitions from Confluent Schema Registry. Generates typed data models and validates schema compatibility using the Schema Registry REST API."
github_stars: 32487
verification: "security_reviewed"
source: "https://github.com/apache/kafka"
category: "Data Extraction & Transformation"
framework: "Codex"
tool_ecosystem:
github_repo: "apache/kafka"
github_stars: 32487
---
# Apache Kafka Schema Extractor
Extracts and transforms Avro, Protobuf, and JSON Schema definitions from Confluent Schema Registry. Generates typed data models and validates schema compatibility using the Schema Registry REST API.
## Installation
Use the upstream install or setup path that matches your environment:
- docker run -p 9092:9092 apache/kafka:latest
Requirements and caveats from upstream:
- Using docker image:
- See [docker/README.md](docker/README.md) for detailed information.
Basic usage or getting-started notes:
- ### Build a JAR and run it
- ### Run unit/integration tests
- ./gradlew test -Pkafka.test.run.flaky=true # runs tests that are marked as flaky
- Source: https://github.com/apache/kafka
- Extracted from upstream docs: https://raw.githubusercontent.com/apache/kafka/HEAD/README.md
## Source
- [Agent Skill Exchange](https://agentskillexchange.com/skills/apache-kafka-schema-extractor/)
