# Kafka Mcp Server

> MCP server from pavanjava/kafka_mcp_server.

- **Type:** MCP server
- **Install:** `agentstack add mcp-pavanjava-kafka-mcp-server`
- **Verified:** Yes — security-reviewed for prompt injection and unsafe behavior
- **Seller:** [pavanjava](https://agentstack.voostack.com/s/pavanjava)
- **Installs:** 0
- **Category:** [Integrations](https://agentstack.voostack.com/c/integrations)
- **Latest version:** 0.1.0
- **License:** Apache-2.0
- **Upstream author:** [pavanjava](https://github.com/pavanjava)
- **Source:** https://github.com/pavanjava/kafka_mcp_server

## Install

```sh
agentstack add mcp-pavanjava-kafka-mcp-server
```

Requires the [AgentStack CLI](https://agentstack.voostack.com/docs/cli). Works with Claude Code, Cursor, and any MCP-compatible agent.

## About

[](https://mseep.ai/app/f159a924-db1c-42f8-825b-b8a1795c1437)

# Kafka MCP Server

A Message Context Protocol (MCP) server that integrates with Apache Kafka to provide publish and consume functionalities for LLM and Agentic applications.

## Overview

This project implements a server that allows AI models to interact with Kafka topics through a standardized interface. It supports:

- Publishing messages to Kafka topics
- Consuming messages from Kafka topics

## Prerequisites

- Python 3.8+
- Apache Kafka instance
- Python dependencies (see Installation section)

## Installation

1. Clone the repository:
   ```bash
   git clone 
   cd 
   ```

2. Create a virtual environment and activate it:
   ```bash
   python -m venv venv
   source venv/bin/activate  # On Windows, use: venv\Scripts\activate
   ```

3. Install the required dependencies:
   ```bash
   pip install -r requirements.txt
   ```

   If no requirements.txt exists, install the following packages:
   ```bash
   pip install aiokafka python-dotenv pydantic-settings mcp-server
   ```

## Configuration

Create a `.env` file in the project root with the following variables:

```
# Kafka Configuration
KAFKA_BOOTSTRAP_SERVERS=localhost:9092
TOPIC_NAME=your-topic-name
IS_TOPIC_READ_FROM_BEGINNING=False
DEFAULT_GROUP_ID_FOR_CONSUMER=kafka-mcp-group

# Optional: Custom Tool Descriptions
# TOOL_PUBLISH_DESCRIPTION="Custom description for the publish tool"
# TOOL_CONSUME_DESCRIPTION="Custom description for the consume tool"
```

## Usage

### Running the Server

You can run the server using the provided `main.py` script:

```bash
python main.py --transport stdio
```

Available transport options:
- `stdio`: Standard input/output (default)
- `sse`: Server-Sent Events

### Integrating with Claude Desktop

To use this Kafka MCP server with Claude Desktop, add the following configuration to your Claude Desktop configuration file:

```json
{
    "mcpServers": {
        "kafka": {
            "command": "python",
            "args": [
                "/main.py"
            ]
        }
    }
}
```

Replace `` with the absolute path to your project directory.

## Project Structure

- `main.py`: Entry point for the application
- `kafka.py`: Kafka connector implementation
- `server.py`: MCP server implementation with tools for Kafka interaction
- `settings.py`: Configuration management using Pydantic

## Available Tools

### kafka-publish

Publishes information to the configured Kafka topic.

### kafka-consume

consume information from the configured Kafka topic.
- Note: once a message is read from the topic it can not be read again using the same groupid

### Create-Topic
Creates a new Kafka topic with specified parameters.
- **Options**:
   - `--topic`Name of the topic to create
   - `--partitions`Number of partitions to allocate
   - `--replication-factor`Replication factor across brokers
   - `--config`(optional) Topic-level configuration overrides (e.g., `retention.ms=604800000`)

### Delete-Topic
Deletes an existing Kafka topic.
- **Options**:
   - `--topic`Name of the topic to delete
   - `--timeout`(optional) Time to wait for deletion to complete

### List-Topics
Lists all topics in the cluster (or filtered by pattern).
- **Options**:
   - `--bootstrap-server`Broker address
   - `--pattern`(optional) Regular expression to filter topic names
   - `--exclude-internal`(optional) Exclude internal topics (default: true)

### Topic-Configuration
Displays or alters configuration for one or more topics.
- **Options**:
   - `--describe`Show current configs for a topic
   - `--alter`Modify configs (e.g., `--add-config retention.ms=86400000,--delete-config cleanup.policy`)
   - `--topic`Name of the topic

### Topic-Metadata
Retrieves metadata about a topic or the cluster.
- **Options**:
   - `--topic`(If provided) Fetch metadata only for this topic
   - `--bootstrap-server`Broker address
   - `--include-offline`(optional) Include brokers or partitions that are offline

## Source & license

This open-source MCP server is cataloged on AgentStack and links to its original source — we do not rehost the code.

- **Author:** [pavanjava](https://github.com/pavanjava)
- **Source:** [pavanjava/kafka_mcp_server](https://github.com/pavanjava/kafka_mcp_server)
- **License:** Apache-2.0

Install and usage instructions live in the source repository linked above.

## Pricing

- **Free** — Free

## Security capabilities

Automated source analysis of v0.1.0 — what this tool can access:

- **Network access:** no
- **Filesystem access:** no
- **Shell / process execution:** no
- **Environment & secrets:** yes
- **Dynamic code execution:** no

*"Yes" means the capability is present in the source — more access means more to trust, not that it is unsafe.*


## Versions

- **0.1.0** — security scan: passed — Imported from the upstream source.

## Links

- Listing page: https://agentstack.voostack.com/l/mcp-pavanjava-kafka-mcp-server
- Seller: https://agentstack.voostack.com/s/pavanjava
- Browse the marketplace: https://agentstack.voostack.com/browse

---
Listed on AgentStack — the marketplace for AI agent skills and MCP servers. Every listing is security-reviewed. Creators keep 70%.