lensesio/agentic-engineering-for-apache-kafka
View on GitHub ↗AI agent skills for building, operating and troubleshooting Apache Kafka applications. Topic audit, consumer lag, schema review, security, connectors and DLQ
56 ★16 forksPythonUpdated 2mo ago
What you need to know
An MCP server from Lenses.io that connects to Apache Kafka, providing tools to inspect brokers, topics, consumer groups, and messages and run streaming queries for agentic data workflows.
Install
Configure with Kafka connection details (bootstrap servers) and register with the MCP client.
Usage
- •Browse topics, read messages, inspect consumer groups, and run SQL over streams via tools.
Key features
- ✓Apache Kafka integration
- ✓topic browsing
- ✓consumer group inspection
- ✓streaming SQL
- ✓message reading
Best for
Data engineers managing Kafka clusters from AI assistants.
Platforms: macOS · Linux · WindowsClients: Claude Desktop · generic MCP clients
Reviewed 2026-08-11
Topics
agent-skillsagentic-engineeringapache-kafkaclaude-codecontext-engineeringcursordata-engineeringdevopskafkakafka-connectlensesmcpmodel-context-protocolplatform-engineeringreal-time-dataschema-registryskillsstreamingstreaming-data
- Stars
- 56★
- Forks
- 16
- Language
- Python
- License
- MIT
- Created
- 2026-01-26
- Last push
- 2026-06-15