---
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/)