Atlas / MCP servers / aywengo / Kafka Schema Registry

Kafka Schema RegistryBLOCK

Name: Kafka Schema Registry
Author: aywengo

mcp/aywengo/kafka-schema-registry

MCP server by aywengo · apache kafka · claude desktop · cursor · Audited 2026-10-08

⚑ Report / re-scan Source ↗

A comprehensive Message Control Protocol (MCP) server for Kafka Schema Registry.

Verdict

BLOCK

Grade

Trust score

69 /100

Exposed tools

9 5r · 4w · 0d

Transport

streamable-http

License

MIT

Stars

Overview

From the repository's own README, as read at the audited commit. Badges and raw HTML are left out.

[](https://mseep.ai/app/aywengo-kafka-schema-reg-mcp) [](https://opensource.org/licenses/MIT) [](https://www.python.org/downloads/) [](https://hub.docker.com/r/aywengo/kafka-schema-reg-mcp) [](https://github.com/aywengo/kafka-schema-reg-mcp/releases) [](https://github.com/aywengo/kafka-schema-reg-mcp/issues) [](https://hub.docker.com/r/aywengo/kafka-schema-reg-mcp) [](https://github.com/aywengo/kafka-schema-reg-mcp/graphs/commit-activity) [](https://modelcontextprotocol.io) [](https://archestra.ai/mcp-catalog/aywengo__kafka-schema-reg-mcp)

A comprehensive Model Context Protocol (MCP) server that provides Claude Desktop and other MCP clients with tools for Kafka Schema Registry operations. Features advanced schema context support, multi-registry management, and comprehensive schema export capabilities.

**🎯 True MC

Read from source at commit 43d99e4a52d3OBSERVED · 2026-10-08

Connect

Built from this server's own package name, version and transport as found in its source — not copied from anyone's documentation, so it cannot drift against a page we do not control. Replace the environment placeholders with a token scoped to the least it needs.

claude-code

claude mcp add kafka-schema-reg-mcp-inspector-tests --env ALLOW_DEV_TOKENS=${ALLOW_DEV_TOKENS} --env AUTH_AUDIENCE=${AUTH_AUDIENCE} --env AUTH_CLIENT_REG_ENABLED=${AUTH_CLIENT_REG_ENABLED} --env AUTH_DEFAULT_SCOPES=${AUTH_DEFAULT_SCOPES} -- npx -y [email protected]

claude-desktop

{
  "mcpServers": {
    "kafka-schema-reg-mcp-inspector-tests": {
      "command": "npx",
      "args": [
        "-y",
        "[email protected]"
      ],
      "env": {
        "ALLOW_DEV_TOKENS": "${ALLOW_DEV_TOKENS}",
        "AUTH_AUDIENCE": "${AUTH_AUDIENCE}",
        "AUTH_CLIENT_REG_ENABLED": "${AUTH_CLIENT_REG_ENABLED}",
        "AUTH_DEFAULT_SCOPES": "${AUTH_DEFAULT_SCOPES}"
      }
    }
  }
}

Exposed tools (9)

5 read · 4 write · 0 destructive.

Tool	Risk	Description
`abort_workflow`	read	Abort an active workflow.
`describe_workflow`	read	Get detailed workflow information.
`guided_context_reorganization`	write	Convenience method to start Context Reorganization workflow.
`guided_disaster_recovery`	write	Convenience method to start Disaster Recovery workflow.
`guided_schema_migration`	write	Convenience method to start Schema Migration workflow.
`list_workflows`	read	List all available workflows.
`ping`	read
`start_workflow`	write	Start a multi-step workflow.
`workflow_status`	read	Get workflow status.

Trust audit

BLOCKgrade D · trust 69/100 Do not install this without reading the findings. The audit found something that could harm you or your machine.

Layer	What it checks	Result
L0	Provenance & inventory	PASS
L1	Static analysis of the code	FAIL
L2	Instruction surface (what it tells the agent)	WARN
L3	Class-specific surface	PASS
L4	Behavioural (sandbox)	SKIPPED

What the source does

Filesystem: declared (3 observation(s))
Network: declared (11 observation(s))
Shell: none-observed
Dependencies: not all pinned
Secrets in source: found

Findings (25)

HIGHNetwork egress · net.tls_off · CWE-200, CWE-319

schema_registry_common.py:300

session.verify = False

Why it matters. certificate verification is disabled

Fix. leave verification on