Kafka MCP

by wklee610• 13•• Scanned•Claim this listing•Request removal

Coding Agentsapache kafkaapache kafka consumerapache kafka producerclaude desktopkafka

MCP Server for Apache Kafka

Kafka MCP is an open-source mcp server by wklee610, written mainly in Python, with 13 GitHub stars and the Apache-2.0 license. Its code was last updated Aug 23, 2026.

Scan summary: scanned Nov 5, 2026 at commit 0b3bf47. Seen able to connect to the internet. Scan policy

about README security reviews

How to install Kafka MCP

Built from the start command in the project's README: docker run -i --rm -e KAFKA_BOOTSTRAP_SERVERS=host.docker.internal:9092 kafka-mcp. Check the README for required keys or settings.

Claude Code · Terminal

claude mcp add kafka-mcp -- docker run -i --rm -e KAFKA_BOOTSTRAP_SERVERS=host.docker.internal:9092 kafka-mcp

Claude Desktop · claude_desktop_config.json

{
  "mcpServers": {
    "kafka-mcp": {
      "command": "docker",
      "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "KAFKA_BOOTSTRAP_SERVERS=host.docker.internal:9092",
        "kafka-mcp"
      ]
    }
  }
}

Cursor · .cursor/mcp.json

{
  "mcpServers": {
    "kafka-mcp": {
      "command": "docker",
      "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "KAFKA_BOOTSTRAP_SERVERS=host.docker.internal:9092",
        "kafka-mcp"
      ]
    }
  }
}

VS Code · Terminal

code --add-mcp '{"name":"kafka-mcp","command":"docker","args":["run","-i","--rm","-e","KAFKA_BOOTSTRAP_SERVERS=host.docker.internal:9092","kafka-mcp"]}'

What Kafka MCP can touch

Run shell commandsNot seen in this scan
Run dynamic codeNot seen in this scan
Read or write filesNot seen in this scan
Read environment and secretsNot seen in this scan
Control a web browserNot seen in this scan
Connect to databasesNot seen in this scan
Read or send messagesNot seen in this scan
Touch money or tradingNot seen in this scan
Connect to the internetContacted pypi.org

"Not seen" means our checks did not find it, and the tool may still do it. Covers commit 0b3bf47, Nov 5, 2026. See the scan policy.

Before you install Kafka MCP

AgenticMart scanned Kafka MCP on Nov 5, 2026 with automated checks for hidden code, known-malicious packages, leaked secrets and vulnerable dependencies. The result covers one commit under our scan policy, so review what access you give it and check any advisories shown here.

What it can access

An MCP server is a program your AI app starts and talks to. A local one runs with your user's permissions: it can see the files, environment variables and network your account can.

Before you install

Pin the version you reviewed instead of always installing the latest release.
Read the tool list or scripts before the first run, and keep approval prompts on for actions that write, send or delete.

Maintained by wklee610 on GitHub, 13 stars and 3 forks. Popularity is not proof of safety.
Last code change: Aug 23, 2026.
Open-source license: Apache-2.0.

Read the scan report What our scan checks

Tools Kafka MCP exposes (19)

Listed by the server itself during our scan of commit 0b3bf47.

describe_cluster
Returns information about the Kafka cluster (brokers, controller).
describe_brokers
Returns a list of brokers with their details.
list_topics
Returns a list of all topic names in the cluster.
describe_topic
Returns detailed information about a specific topic.
create_topic
Creates a new topic.
delete_topic
Deletes a topic.
create_partitions
Increases the number of partitions for a topic. Note: Partition count can only be increased, not decreased.
describe_configs
Get dynamic configs for a resource. resource_type: "topic", "broker", or "group" (case insensitive)
alter_configs
Update dynamic configs for a resource. resource_type: "topic", "broker", or "group" configs: Dictionary of config key-value pairs
consume_messages
Consumes messages from a topic. offset_spec: 'earliest', 'latest', or specific integer offset. timeout: seconds to wait for messages.
list_consumer_groups
Lists all consumer groups.
describe_consumer_group
Describes a specific consumer group.
get_consumer_group_offsets
Get the committed offsets and lag for a specific consumer group and topic. Returns the committed offset, high/low watermarks, and calculated lag for each partition.
reset_consumer_group_offset
Resets the offset of a consumer group using AdminClient. offset_spec: 'earliest', 'latest', or a specific integer offset string. dry_run: If True, only calculates and returns the proposed offset changes without applying them. force: If True, forces the modification even if the group is active or STA
rewind_consumer_group_offset_by_timestamp
Rewinds consumer group offsets manually based on a specific timestamp. Finds offsets matching the timestamp using Consumer, then sets using AdminClient. dry_run: If True, only calculates and returns the proposed offset changes without applying them. force: If True, forces the modification even if th
produce_message
Produces a message to a topic.
describe_cluster_health
Summarizes Kafka health signals exposed by Prometheus JMX Exporter.
get_broker_metrics
Returns curated or filtered raw JMX Exporter metrics for one or all brokers.
get_topic_metrics
Returns JMX Exporter metrics labeled for a Kafka topic.

Hosts it contacted while running

pypi.org

Kafka MCP is an open-source mcp server by wklee610, written mainly in Python. MCP Server for Apache Kafka

At a glance

Stars: 13
Forks: 3
Language: Python
License: Apache-2.0
Created: Feb 2026
Last update: Aug 23, 2026
Type: MCP Server
Price: Free

Topics

apache-kafkaapache-kafka-consumerapache-kafka-producerclaude-desktopkafkakafka-connectorkafka-pythonmcpmcp-servermcp-serversmcp-tools

Questions about Kafka MCP

What is Kafka MCP?

MCP Server for Apache Kafka

Who maintains Kafka MCP?

Kafka MCP is maintained by wklee610 on GitHub (wklee610/kafka-mcp). AgenticMart lists it from public repository data.

Is Kafka MCP safe to use?

What license does Kafka MCP use?

It is published under the Apache-2.0 license.

Guides

Kafka MCP alternatives

View more →

Similar mcp servers in Coding Agents, ranked by GitHub stars. Compare licence, recent activity and scan status before you choose.

Name	Stars	Licence	Last updated	Scan
Kafka MCP (this page) wklee610	13	Apache-2.0	Aug 23, 2026	Scanned, no flagged issues
Context Mode mksglu	33k	None found	Nov 1, 2026	Not scanned yet
Serena oraios	31k	None found	Oct 28, 2026	Not scanned yet
Fastmcp PrefectHQ	28k	Apache-2.0	Nov 1, 2026	Scanned, no flagged issues
Nuclear nukeop	19k	AGPL-3.0	Nov 1, 2026	Scanned, no flagged issues
MCP For Beginners microsoft	18k	MIT	Oct 30, 2026	Scanned, no flagged issues