Metadata-Version: 2.4
Name: kafka-mcp
Version: 0.5.0
Summary: Apache Kafka (REST Proxy / native) API + MCP Server + A2A Server for Agentic AI!
Author-email: Audel Rouhi <knucklessg1@gmail.com>
License: MIT
Classifier: Development Status :: 4 - Beta
Classifier: License :: OSI Approved :: MIT License
Classifier: Environment :: Console
Classifier: Operating System :: POSIX :: Linux
Classifier: Programming Language :: Python :: 3
Requires-Python: <3.14,>=3.11
Description-Content-Type: text/markdown
License-File: LICENSE
Requires-Dist: agent-utilities>=0.45.0
Requires-Dist: requests>=2.31.0
Provides-Extra: mcp
Requires-Dist: agent-utilities[mcp]>=0.45.0; extra == "mcp"
Provides-Extra: agent
Requires-Dist: agent-utilities[agent,logfire]>=0.45.0; extra == "agent"
Provides-Extra: native
Requires-Dist: confluent-kafka>=2.3.0; extra == "native"
Provides-Extra: all
Requires-Dist: agent-utilities[agent,logfire,mcp]>=0.45.0; extra == "all"
Provides-Extra: test
Requires-Dist: pytest-xdist>=3.6.0; extra == "test"
Requires-Dist: pytest; extra == "test"
Requires-Dist: pytest-asyncio; extra == "test"
Requires-Dist: pytest-cov; extra == "test"
Dynamic: license-file

# kafka-mcp

A Model Context Protocol (MCP) server for Kafka integration.

## Table of Contents
- [Overview](#overview)
- [Installation](#installation)
- [Usage](#usage)
- [Architecture](#architecture)
- [Deployment](#deployment)
- [Environment Variables](#environment-variables)
- [MCP Tools](#mcp-tools)

## Overview
kafka-mcp exposes a standardized interface to interact with Kafka using the Model Context Protocol.

## Installation
```bash
pip install -e .
```

## Usage
Run the MCP server directly:
```bash
python -m kafka_mcp
```

## Architecture
See `/docs` for architectural diagrams and further documentation.

## Deployment
### Bare-metal
```bash
python -m kafka_mcp.agent_server
```

### Docker
```bash
docker compose -f docker/agent.compose.yml up -d
```

## Environment Variables
| Variable | Description |
|----------|-------------|
| `KAFKA_BOOTSTRAP_SERVERS` | Kafka brokers |
| `KAFKA_SCHEMA_REGISTRY_URL` | Schema registry |

## MCP Tools
| Tool | Description |
|------|-------------|
| `get_kafka_info` | Retrieve basic information from Kafka |
| `query_kafka` | Run a query against the Kafka instance |
