williajm/mcp_kafka
If you are the rightful owner of mcp_kafka and would like to certify it and/or have it hosted online, please leave a comment on the right or send an email to dayong@mcphub.com.
MCP Kafka is a Model Context Protocol server designed to provide AI assistants with secure and controlled access to Apache Kafka clusters.
Tools
Functions exposed to the LLM to take actions
kafka_list_topics
List all topics with partition counts
kafka_describe_topic
Get detailed topic info and configuration
kafka_create_topic
Create a new topic with partitions, replication factor, and config
kafka_consume_messages
Peek at messages (no offset commit)
kafka_produce_message
Produce a message with optional key, headers, and partition
kafka_list_consumer_groups
List all consumer groups
kafka_describe_consumer_group
Get group details, members, and lag
kafka_get_consumer_lag
Get lag per partition
kafka_reset_offsets
Reset consumer group offsets to earliest, latest, or specific offset
kafka_cluster_info
Get cluster metadata
kafka_list_brokers
List all brokers
kafka_get_watermarks
Get topic partition watermarks
Prompts
Interactive templates invoked by user choice
No prompts
Resources
Contextual data attached and managed by the client