About Kafka MCP Python
Kafka MCP Python is an MCP server published by veenaypatil in the Data category: mCP Server for interacting with Kafka.
Six months or more without a commit doesn't mean the server is broken, but check the open issues before depending on it in production.
Install
git clone https://github.com/veenaypatil/kafka-mcp-pythonThis server has no ConduID identity, so agent calls to it are not receipted. Pin the version you install and review the source before granting it credentials.
Tools (12)
clear_topic_consumers_cacheReset cache
Parameters not published.
consume_messagesFetch messages with strategies latest / earliest / timestamp
Parameters not published.
count_messages_last_hoursCount messages produced in last X hours
Parameters not published.
describe_consumer_groupMembers, offsets, lag per topic/partition
Parameters not published.
describe_topicPartitions (leader/replicas/ISR), retention, replication factor, disk size
Parameters not published.
generate_topic_consumers_reportCSV of topics → consumers
Parameters not published.
get_cache_statusCache diagnostics
Parameters not published.
get_consumer_group_lagAggregated lag view
Parameters not published.
get_topic_consumersList consumer groups per topic (cached)
Parameters not published.
get_topic_partitionsGet partition count only
Parameters not published.
get_topic_sizeDisk usage via kafka-log-dirs
Parameters not published.
produce_messageSend a message
Parameters not published.
Ask AI
Ask AI about Kafka MCP Python
Powered by Claude
Security checks
6 checks have not been run yet.