Read-only Kafka observability MCP server: cluster health, consumer lag, and replay-readiness.
Connect Runs on your machine
claude mcp add kafka-sentinel-mcp -e KAFKA_BOOTSTRAP=<KAFKA_BOOTSTRAP> -e KAFKA_SECURITY_PROTOCOL=<KAFKA_SECURITY_PROTOCOL> -e KAFKA_SASL_MECHANISM=<KAFKA_SASL_MECHANISM> -e KAFKA_SASL_USERNAME=<KAFKA_SASL_USERNAME> -e KAFKA_SASL_PASSWORD=<KAFKA_SASL_PASSWORD> -e KAFKA_SSL_CA_LOCATION=<KAFKA_SSL_CA_LOCATION> -- uvx kafka-sentinel-mcp==0.1.2{
"mcpServers": {
"kafka-sentinel-mcp": {
"command": "uvx",
"args": [
"kafka-sentinel-mcp==0.1.2"
],
"env": {
"KAFKA_BOOTSTRAP": "<KAFKA_BOOTSTRAP>",
"KAFKA_SECURITY_PROTOCOL": "<KAFKA_SECURITY_PROTOCOL>",
"KAFKA_SASL_MECHANISM": "<KAFKA_SASL_MECHANISM>",
"KAFKA_SASL_USERNAME": "<KAFKA_SASL_USERNAME>",
"KAFKA_SASL_PASSWORD": "<KAFKA_SASL_PASSWORD>",
"KAFKA_SSL_CA_LOCATION": "<KAFKA_SSL_CA_LOCATION>"
}
}
}
}{
"mcpServers": {
"kafka-sentinel-mcp": {
"command": "uvx",
"args": [
"kafka-sentinel-mcp==0.1.2"
],
"env": {
"KAFKA_BOOTSTRAP": "<KAFKA_BOOTSTRAP>",
"KAFKA_SECURITY_PROTOCOL": "<KAFKA_SECURITY_PROTOCOL>",
"KAFKA_SASL_MECHANISM": "<KAFKA_SASL_MECHANISM>",
"KAFKA_SASL_USERNAME": "<KAFKA_SASL_USERNAME>",
"KAFKA_SASL_PASSWORD": "<KAFKA_SASL_PASSWORD>",
"KAFKA_SSL_CA_LOCATION": "<KAFKA_SSL_CA_LOCATION>"
}
}
}
}{
"servers": {
"kafka-sentinel-mcp": {
"type": "stdio",
"command": "uvx",
"args": [
"kafka-sentinel-mcp==0.1.2"
],
"env": {
"KAFKA_BOOTSTRAP": "<KAFKA_BOOTSTRAP>",
"KAFKA_SECURITY_PROTOCOL": "<KAFKA_SECURITY_PROTOCOL>",
"KAFKA_SASL_MECHANISM": "<KAFKA_SASL_MECHANISM>",
"KAFKA_SASL_USERNAME": "<KAFKA_SASL_USERNAME>",
"KAFKA_SASL_PASSWORD": "<KAFKA_SASL_PASSWORD>",
"KAFKA_SSL_CA_LOCATION": "<KAFKA_SSL_CA_LOCATION>"
}
}
}
}Replace the values in angle brackets with your own. Keys stay on your machine; we never see them.
Tools
This server runs locally, so its tools are listed by your MCP client once it starts.
Environment variables
| Name | Description |
|---|---|
KAFKA_BOOTSTRAPRequired | Kafka bootstrap servers, e.g. broker1:9092,broker2:9092 |
KAFKA_SECURITY_PROTOCOLOptional | librdkafka security.protocol, e.g. SASL_SSL |
KAFKA_SASL_MECHANISMOptional | librdkafka sasl.mechanism, e.g. PLAIN or SCRAM-SHA-512 |
KAFKA_SASL_USERNAMEOptional | SASL username |
KAFKA_SASL_PASSWORDOptional, secret | SASL password |
KAFKA_SSL_CA_LOCATIONOptional | Path to CA certificate for SSL |
Details
| Package | [email protected] (PYPI, stdio) |
| First published | 23 Jul 2026 |
| Last updated | 23 Jul 2026 |
| Registry name | io.github.sanjay-amu/kafka-sentinel-mcp |
More cloud and devops servers See all
Listing data from the official MCP registry. Status and tools from NestDaddy's daily check. Browse all MCP servers.