Kafka

关于

This Model Context Protocol (MCP) server is engineered to simplify interactions with Kafka clusters by answering plain-text questions about topics, consumers, and their operational status. It integrates a comprehensive set of tools for tasks such as fetching and producing messages, inspecting topic partitions and sizes, monitoring consumer group lag, and generating detailed reports on topic-consumer relationships. Designed for in-house environments, it streamlines Kafka diagnostics, monitoring, and general data accessibility for operators and developers.

主要功能

• Describe and track consumer group members, offsets, and aggregate lag
• 0 GitHub stars
• Consume and produce messages to Kafka topics with various strategies
• Monitor Kafka topic metadata including partitions, retention, and disk usage
• Utilizes an in-process cache for consumer group lookups to enhance performance
• Generate detailed CSV reports on topic-to-consumer group relationships

使用案例

• Automating Kafka operational tasks and metadata extraction via a programmatic interface
• Providing a conversational or plain-text interface for real-time Kafka cluster information
• Troubleshooting Kafka consumer group lag and topic health issues