{"name":"io.github.sanjay-amu/kafka-sentinel-mcp","slug":"sanjay-amu-kafka-sentinel-mcp","title":"Kafka Sentinel","description":"Read-only Kafka observability MCP server: cluster health, consumer lag, and replay-readiness.","url":"https://mcp.market/server/sanjay-amu-kafka-sentinel-mcp","rating":null,"grade":"B","score":78,"certified":false,"status":"active","category":"other","tags":[],"presence":{"score":23,"stars":3,"forks":0,"downloads_week":24,"last_push_at":"2026-07-31T16:50:53.000Z","license":"MIT"},"uptime":null,"claimed":false,"transport":"pypi","callable_via_gateway":false,"default_price_micros":0,"repository":"https://github.com/sanjay-amu/kafka-sentinel-mcp","website":null,"version":"0.1.2","remotes":[],"packages":[{"registryType":"pypi","identifier":"kafka-sentinel-mcp","version":"0.1.2","transport":{"type":"stdio"},"environmentVariables":[{"description":"Kafka bootstrap servers, e.g. broker1:9092,broker2:9092","isRequired":true,"format":"string","name":"KAFKA_BOOTSTRAP"},{"description":"librdkafka security.protocol, e.g. SASL_SSL","format":"string","name":"KAFKA_SECURITY_PROTOCOL"},{"description":"librdkafka sasl.mechanism, e.g. PLAIN or SCRAM-SHA-512","format":"string","name":"KAFKA_SASL_MECHANISM"},{"description":"SASL username","format":"string","name":"KAFKA_SASL_USERNAME"},{"description":"SASL password","format":"string","isSecret":true,"name":"KAFKA_SASL_PASSWORD"},{"description":"Path to CA certificate for SSL","format":"string","name":"KAFKA_SSL_CA_LOCATION"}]}],"tools":[{"name":"cluster_health","description":"Broker count, controller, and under-replicated / offline partition summary.","write_action":false,"price_micros":0,"input_schema":null},{"name":"consumer_lag","description":"Per-partition lag for a consumer group on a topic: committed offset vs log-end offset. committed = -1 means no offset stored.","write_action":false,"price_micros":0,"input_schema":null},{"name":"incident_snapshot","description":"One-call bundle: cluster health + lag + audit + partition state + replay readiness. Timestamped for postmortems.","write_action":false,"price_micros":0,"input_schema":null},{"name":"list_consumer_groups","description":"List all consumer group IDs on the cluster with their state. Use this first if you don't already know a group name.","write_action":false,"price_micros":0,"input_schema":null},{"name":"list_topics","description":"List all non-internal topics with partition count and replication factor. Use this first if you don't already know a topic name — every other tool needs one.","write_action":false,"price_micros":0,"input_schema":null},{"name":"partition_state","description":"Leader/ISR state per partition, plus leader skew across brokers.","write_action":false,"price_micros":0,"input_schema":null},{"name":"replay_readiness","description":"Can this group still replay everything since its committed offsets, or has retention already deleted part of the gap?","write_action":false,"price_micros":0,"input_schema":null},{"name":"topic_audit","description":"Replication and durability config audit for a topic. Flags settings that violate mission-critical best practice.","write_action":false,"price_micros":0,"input_schema":null}],"scan":{"score":78,"grade":"B","scanned_at":"2026-09-25T12:08:39.060Z","report":{"scannerVersion":"0.1.9","scannedAt":"2026-09-25T12:08:39.001Z","components":{"code":{"score":25,"max":25,"notes":["4 source files scanned"]},"reliability":{"score":-1,"max":20,"notes":["no gateway calls yet and no remote to probe"]},"poisoning":{"score":-1,"max":15,"notes":["tools not inspected (local package is not executed); not counted"]},"auth":{"score":6,"max":15,"notes":["static API keys via environment variables"]},"maintenance":{"score":12,"max":15,"notes":["last push 56 days ago"]},"identity":{"score":8,"max":10,"notes":["registry namespace matches repository owner","GitHub account older than a year"]}},"findings":[],"inputs":{"packages":[{"registryType":"pypi","identifier":"kafka-sentinel-mcp","version":"0.1.2","found":true,"weeklyDownloads":24,"license":"MIT","dependencyCount":5,"publishedAt":"2026-07-23T23:13:25.494250Z","repositoryUrl":"https://github.com/sanjay-amu/kafka-sentinel-mcp"}],"repo":{"found":true,"owner":"sanjay-amu","repo":"kafka-sentinel-mcp","archived":false,"pushedAt":"2026-07-31T16:50:53Z","stars":3,"forks":0,"openIssues":0,"ownerType":"User","ownerAvatarUrl":"https://avatars.githubusercontent.com/u/160977037?v=4","ownerCreatedAt":"2024-02-22T23:06:20Z","license":"MIT"},"icon":{"url":null,"source":"none"},"presence":{"stars":3,"forks":0,"downloadsWeek":24,"license":"MIT","lastPushAt":"2026-07-31T16:50:53.000Z","score":23}}}},"grade_history":[],"reviews":[]}