MCP, MCP server
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.
Compatibility: Not stated.
Grade C
One Medium finding. Read the findings before installing.
Not a guarantee. A hygiene check of the source at the commit shown, not a security audit.
Rescanned at commit 225969283e9e, unchanged since the check below.
INSTALL_REMOTE_SCRIPT
Why this grade
- INSTALL_REMOTE_SCRIPT Medium
Fetches a script from the network and runs it (a pipe to a shell, or an install hook with a URL).
kubernetes/README.md, line 57
curl https://raw.githubusercontent.com/helm/helm/main/scripts/get-helm-3 | bash
Any High, or two or more Medium findings, give D. One Medium gives C. Low findings or a security Note give B. Each code names a finding behind the letter.
If you think this grade is wrong, email [email protected] with the entry link and your evidence. We aim to acknowledge within two working days and decide within seven. If we confirm an error, we aim to correct it within 24 hours of confirming it. These are aims, not guarantees.
Grades are a hygiene check of the source at the commit shown, on the date checked, not a security audit or a guarantee. The free directory grades are automated. Before release, a PlugVet engineer reviews every paid report and any grade we hold back, including all F grades, against the source code and the evidence we quote.
What was checked
Plain notes from the hygiene checks.
Permissions
Note
requests shell access. The manifest names this permission.
PERMISSION_SHELL_DECLARED
config-examples/mcp-ide-integration.md, line 266
result = subprocess.run([
Install and update
Serious
install fetches a script from the network.
INSTALL_REMOTE_SCRIPT
kubernetes/README.md, line 57
curl https://raw.githubusercontent.com/helm/helm/main/scripts/get-helm-3 | bash
requirements.txt, line 2
fastmcp[tasks]>=3.2.0,<4
glamaai/Dockerfile.glama, line 6
RUN (apt-get update) && (apt-get install -y --no-install-recommends build-essential curl wget software-properties-common libssl-dev zlib1g-dev git) && (rm -rf /var/lib/apt/lists/*)
Network
Concern
can reach a host that is not written as a fixed address. can reach keycloak.example.com. The description does not name that host.
NETWORK_NO_FIXED_HOST NETWORK_UNNAMED_HOST
kafka_schema_registry_unified_mcp.py, line 2825
response = requests.get(endpoint_url, timeout=10)
start-test-env.sh, line 187
if curl -s -f http://localhost:38081/subjects >/dev/null 2>&1; then
start-test-env.sh, line 194
if curl -s -f http://localhost:38082/subjects >/dev/null 2>&1; then
Show more
start-test-env.sh, line 204
if curl -s -f http://localhost:38081/subjects >/dev/null 2>&1 && \
start-test-env.sh, line 205
curl -s -f http://localhost:38082/subjects >/dev/null 2>&1; then
config-examples/setup-ide-mcp.sh, line 81
if curl -s http://localhost:8081/subjects > /dev/null; then
config-examples/setup-ide-mcp.sh, line 88
if curl -s http://localhost:8080/health > /dev/null 2>&1; then
config-examples/setup-ide-mcp.sh, line 95
if curl -s http://localhost:8081/health > /dev/null 2>&1; then
config-examples/setup-ide-mcp.sh, line 113
echo " curl http://localhost:8080/health"
examples/test-jwt-validation.py, line 274
curl -X POST https://keycloak.example.com/realms/your-realm/protocol/openid-connect/token \\
examples/test-jwt-validation.py, line 287
curl -H "Authorization: Bearer YOUR_JWT_TOKEN" \\
examples/test-registry-metadata.py, line 29
response = requests.get(f"{SCHEMA_REGISTRY_URL}/v1/metadata/id", timeout=10)
examples/test-registry-metadata.py, line 50
response = requests.get(f"{SCHEMA_REGISTRY_URL}/v1/metadata/version", timeout=10)
examples/test-registry-metadata.py, line 74
response = requests.post(f"{MCP_SERVER_URL}/mcp/tools/test_registry_connection", json={}, timeout=10)
examples/test-registry-metadata.py, line 86
response = requests.post(f"{MCP_SERVER_URL}/mcp/tools/count_schemas", json={}, timeout=10)
examples/test-registry-metadata.py, line 101
response = requests.post(f"{MCP_SERVER_URL}/mcp/tools/get_registry_info", json={}, timeout=10)
Secrets
Concern
reads a credential or environment file.
SECRETS_ENV_READ SECRETS_PATH_DOTENV
kafka_schema_registry_unified_mcp.py, line 439
os.getenv("SCHEMA_REGISTRY_PASSWORD"),
kafka_schema_registry_unified_mcp.py, line 448
os.getenv("SCHEMA_REGISTRY_PASSWORD_1"),
kafka_schema_registry_unified_mcp.py, line 483
password = os.getenv("SCHEMA_REGISTRY_PASSWORD", "")
Show more
migration_tools.py, line 1035
" - Create a .env file with the environment variables",
migration_tools.py, line 1036
" - Run: docker run -it --rm --env-file .env aywengo/kafka-schema-reg-migrator:latest",
oauth_provider.py, line 103
TOKEN_BINDING_ENABLED = os.getenv("TOKEN_BINDING_ENABLED", "false").lower() in (
oauth_provider.py, line 111
TOKEN_INTROSPECTION_ENABLED = os.getenv("TOKEN_INTROSPECTION_ENABLED", "true").lower() in ("true", "1", "yes", "on")
oauth_provider.py, line 114
TOKEN_REVOCATION_CHECK_ENABLED = os.getenv("TOKEN_REVOCATION_CHECK_ENABLED", "true").lower() in (
oauth_provider.py, line 132
ALLOW_DEV_TOKENS = os.getenv("ALLOW_DEV_TOKENS", "true").lower() in (
schema_registry_common.py, line 32
SINGLE_REGISTRY_PASSWORD = os.getenv("SCHEMA_REGISTRY_PASSWORD", "")
inspector-tests/run-inspector-tests.sh, line 188
env_len=$(jq -r ".mcpServers[\"$server_key\"].env | length" "$temp_config")
inspector-tests/run-inspector-tests.sh, line 201
done < <(jq -r ".mcpServers[\"$server_key\"].env | to_entries[] | [.key, (.value|tostring)] | @tsv" "$temp_config")
.dockerignore, line 59
# Environment files
.dockerignore, line 60
.env
.dockerignore, line 61
.env.local
.dockerignore, line 62
.env.development
Agent instructions
Pass
No instruction to ignore earlier instructions or to hide a step.
Obfuscation
Note
a file was over the read cap and was not fully read.
OBFUSCATION_FILE_OVER_READ_CAP
uv.lock, line 1
version = 1
Licence
Pass
A licence file is present (LICENSE).
Maintainer activity
Pass
The latest commit is within the last 365 days.
Note
Hygiene check of commit 225969283e9e. requests shell access. The manifest names this permission. install fetches a script from the network. can reach a host that is not written as a fixed address. can reach keycloak.example.com. The description does not name that host. reads a credential or environment file. a file was over the read cap and was not fully read.
Date and source
Date checked:
github.com
Commit graded: 225969283e9e329d1b84437f335a955afe9a65ee
This link goes to the original host. PlugVet does not host or check what you download from there, and installing it is your own decision and risk.