Skip to content

wklee610/kafka-mcp

MCP Developer Tools

MCP server for Apache Kafka that allows LLM agents to inspect topics, consumer groups, and safely manage offsets (reset, rewind).

Track releases GitHub
Python Latest 1.1.2 · 2mo ago Security brief →

Features

  • Manage Kafka cluster metadata (describe brokers, list topics)
  • Create, delete, and modify topics and partitions
  • Configure dynamic settings for topics, brokers, and consumer groups
  • Handle consumer group offsets with reset/rewind operations
  • Consume and produce messages from/to Kafka

Recent releases

View all 4 releases →
1.1.1 New feature
Notable features
  • Support for retrieving topic offsets
Full changelog
  • support for retrieving topic offsets

What's Changed

  • fix: claude plugin marketplace json by @wklee610 in https://github.com/wklee610/kafka-mcp/pull/4
  • add: support for retrieving topic offsets by @wklee610 in https://github.com/wklee610/kafka-mcp/pull/5

Full Changelog: https://github.com/wklee610/kafka-mcp/compare/1.1.0...1.1.1

View release on GitHub
1.1.0 Breaking risk
Breaking changes
  • Renamed internal package from kafka-mcp to kafka_mcp
Notable features
  • Added Admin API-based consumer group offset reset
  • Added timestamp-based offset rewind
  • Introduced dry-run mode with impact summary
Full changelog

✨ Highlights

  • Added Admin API-based consumer group offset reset
  • Added timestamp-based offset rewind
  • Introduced dry-run mode with impact summary
  • Improved safety checks before modifying offsets
  • Added logging for offset lookup failures
  • General refactoring

🔄 Project Rename

  • Renamed internal package from kafka-mcp to kafka_mcp
View release on GitHub
1.0.0 Feature
Notable features
  • MCP server implementation based on FastMCP
  • Kafka integration using confluent-kafka
  • Allows LLMs to directly query Kafka metadata
Full changelog
  • MCP server implementation based on FastMCP
  • Kafka integration using confluent-kafka
  • Allows LLMs to directly query Kafka metadata
  • Experimenting with an agent-driven Kafka operations interface
View release on GitHub

Weekly OSS security release digest.

The CVE patches and breaking changes that affected production tools this week. One email, every Sunday.

No spam, unsubscribe anytime.

About

Stars
11
Forks
2
Languages
Python Dockerfile
View on GitHub

Install & Platforms

Install via
docker

Similar tools

confluentinc/mcp-confluent
alexei-led/k8s-mcp-server
mahdin75/geoserver-mcp
1mcp/agent
irskep/persistproc

Beta — feedback welcome: [email protected]