MCP Kafka
Apache Kafka monitoring & management for AI agents (with consumer lag) — governed.
Connector by dockndevai · GitHub account verified by the MCP Registry
Install
Works with Claude Code, Codex, VS Code, Cursor, Windsurf, Claude Desktop. Read the repository before you give any tool access to your data.
npx agentmarket install connector/dockndevai-mcp-kafka
Asks which of your tools to add it to (Claude Code, Codex, Cursor, VS Code, Windsurf, Gemini CLI, Claude Desktop) and shows the change first. See https://agentmart.dev/cli.
Get the weekly diff
The weekly diff: one email a week with new agent tools, notable updates and grade changes, plus security alerts for tools you follow. Double opt-in, one-click unsubscribe.
About
Reviews
Write a reviewNo reviews yet. Installed it? Reviews come from verified installers only. How reviews work
Permissions
What this server can do and what it asks for, from its tool list and install config. Checked Oct 25, 2026.
- Tools
- 5 read · 3 write · 3 delete · 1 not yet classified
- Secrets
- None asked for
- Install scripts
- Not scanned yet
- Runs as
- Node.js package
Tools by what they do 12
Read from the source code; the running server may list different tools.
Read 5 · Look things up without changing anything.
cluster_infodescribe_consumer_groupdescribe_topiclist_consumer_groupslist_topics
Write 3 · Create, change, send or run things.
alter_topic_configcreate_partitionscreate_topic
Delete 3 · Delete, drop, revoke or wipe things.
delete_consumer_groupdelete_topicreset_consumer_group_offsets
Not yet classified 1 · We could not tell from the name and description.
topic_offsets
Secrets and settings it asks for
Other settings (environment variables or headers).
KAFKA_BROKERSKAFKA_MODE
Tools (12)
Read from the source code; the running server may differ. Descriptions are the server’s own words; hidden characters are shown as [U+…].
alter_topic_configAlter topic configUpdate one or more topic-level configuration entries.
cluster_infoCluster infoDescribe the Kafka cluster: brokers, controller, and cluster id.
create_partitionsAdd partitionsIncrease a topic's partition count (cannot decrease). Affects key-based ordering.
create_topicCreate topicCreate a topic with a partition count, replication factor, and optional configs.
delete_consumer_groupDelete consumer groupDelete a consumer group (must have no active members). Requires admin mode AND KAFKA_ALLOW_DELETE=true.
delete_topicDelete topicPermanently delete a topic and its data. Requires admin mode AND KAFKA_ALLOW_DELETE=true. Irreversible.
describe_consumer_groupDescribe consumer group (with lag)Describe a consumer group's state and compute per-partition and total lag across its topics.
describe_topicDescribe topicPartitions, replicas, in-sync replicas, and non-default configs for a topic.
list_consumer_groupsList consumer groupsList consumer groups and their protocol types.
list_topicsList topicsList topic names. Topics outside the allowlist are filtered out.
reset_consumer_group_offsetsReset consumer group offsetsReset a consumer group's committed offsets for a topic to the earliest or latest offset. The group must have no active members. Affects redelivery — use with care.
topic_offsetsTopic offsetsEarliest and latest offsets per partition for a topic (message backlog view).
Signals
- Stars
- 1
- Forks
- 0
- Open issues
- 2
- Weekly downloads
- 37
- Last commit
- Oct 19, 2026 (10 days ago)
- Last release
- Oct 26, 2026 (3 days ago)
- Last package publish
- Sep 29, 2026 (29 days ago)
From GitHub (fetched Oct 24, 2026) and the package registry.
Details
- Registry name
io.github.dockndevai/mcp-kafka- Version
- 0.3.3
- Auth
- No auth
- Packages
- npm @dockndevai/mcp-kafka
- License
- MIT
- Repository
- github.com/dockndevai/mcp-kafka
- First seen
- Oct 24, 2026
- Last checked
- Oct 26, 2026
More from dockndevai
- 0.550score
MCP ClickHouse
dockndevai
ClickHouse query & management for AI agents — SQL-classified read/write/destructive gating.
ConnectorAFreshness: ALocal★ 3↓ 43/wkClaude Code +5 - 0.548score
MCP Azure
dockndevai
Azure Resource Manager inventory & ops for AI agents — governed, confirmation-gated.
ConnectorAFreshness: ALocal★ 1↓ 102/wkClaude Code +5 - 0.546score
MCP Kubernetes
dockndevai
Kubernetes monitoring & ops for AI agents — safe-by-default access modes and guards.
ConnectorAFreshness: ALocal★ 2↓ 40/wkClaude Code +5 - 0.542score
MCP Percona Pg
dockndevai
Manage Percona PostgreSQL + PgBouncer on Kubernetes — safe-by-default access modes and guards.
ConnectorAFreshness: ALocal★ 1↓ 47/wkClaude Code +5 - 0.541score
MCP Azure DevOps
dockndevai
Azure DevOps boards, repos, pipelines & projects for AI agents — governed.
ConnectorAFreshness: ALocal★ 1↓ 43/wkClaude Code +5 - 0.541score
MCP Oci
dockndevai
Oracle Cloud discovery + Terraform generation for AI agents — read-only, secret-safe.
ConnectorAFreshness: ALocal★ 1↓ 40/wkClaude Code +5
Cite this page
MCP Kafka. Agent Mart. https://agentmart.dev/connectors/dockndevai-mcp-kafka (last updated 2026-10-26)