Most of what you do with Kafka day to day is create a topic, describe it, push a test message and read it back — this covers all four in one sentence each. Offset reset is in here too, which is the operation most worth being deliberate about: it changes where a live consumer group resumes.
A natural-language interface to a Kafka cluster. It covers both sides of the data path and the admin surface around it, so "publish this to test-kafka" and "list all topics" both become real Kafka operations.
- `producer` publishes a message to a topic; `consumer` reads messages back off one
- `topic` tools cover `list`, `create`, `delete` and `describe`
- `broker` returns broker information
- `partition` tools return partitions and partition offsets
- `group_offset` tools get and reset consumer group offsets
Python with a virtual environment and the dependencies from `requirements.txt`. Two settings, in `.env` or exported: `BOOTSTRAP_SERVERS` pointing at your cluster, and `MCP_TRANSPORT=stdio`. Run `python3 src/main.py`, or point the client at that path directly. No account or key of its own — whatever your Kafka cluster requires is what it needs. Version 0.1.0.