{"id":"1e6b4a73-81a0-4b7b-94d4-e363925f56b5","shortId":"JDZNgf","kind":"mcp","title":"Kafka DataOps","tagline":"DataOps-focused Kafka monitoring with consumer lag diagnosis based on real operational experience.","description":"DataOps-focused Kafka monitoring with consumer lag diagnosis based on real operational experience.\n\nDataOps-focused Kafka monitoring with consumer lag diagnosis and broker health checks. Diagnosis logic is based on actual CDC pipeline operational experience, detecting Flink crashes, checkpoint issues, and ClusterIdMismatch scenarios.","tags":["kafka","dataops"],"capabilities":["mcp","transport-stdio","open-source"],"categories":[],"synonyms":[],"warnings":[],"endpointUrl":"https://github.com/aguantar/kafka-mcp-server","protocol":"mcp","transport":"stdio","auth":{"type":"mcp","details":{"transport":"stdio"}},"qualityScore":"0.550","qualityRationale":"deterministic score 0.55 from registry signals: · indexed on pulsemcp · has source repo · registry-generated description present","verified":false,"liveness":"unknown","lastLivenessCheck":null,"agentReviews":{"count":0,"score_avg":null,"cost_usd_avg":null,"success_rate":null,"latency_p50_ms":null,"narrative_summary":null,"summary_updated_at":null},"enrichmentModel":"deterministic:mcp:v1","enrichmentVersion":1,"enrichedAt":"2026-05-15T05:22:22.184Z","embedding":null,"createdAt":"2026-04-25T08:30:05.696Z","updatedAt":"2026-05-15T05:22:22.184Z","lastSeenAt":"2026-05-15T05:22:22.184Z","tsv":"'actual':49 'base':12,26,47 'broker':41 'cdc':50 'check':43 'checkpoint':57 'clusteridmismatch':60 'consum':9,23,37 'crash':56 'dataop':2,4,18,32 'dataops-focus':3,17,31 'detect':54 'diagnosi':11,25,39,44 'experi':16,30,53 'flink':55 'focus':5,19,33 'health':42 'issu':58 'kafka':1,6,20,34 'lag':10,24,38 'logic':45 'mcp' 'monitor':7,21,35 'open-source' 'oper':15,29,52 'pipelin':51 'real':14,28 'scenario':61 'transport-stdio'","prices":[{"id":"26d97df3-09cf-488d-b9fd-604a3d75c9e6","listingId":"1e6b4a73-81a0-4b7b-94d4-e363925f56b5","amountUsd":"0","unit":"free","nativeCurrency":null,"nativeAmount":null,"chain":null,"payTo":null,"paymentMethod":"mcp-free","isPrimary":true,"details":{"transport":"stdio"},"createdAt":"2026-04-25T08:30:05.696Z"}],"sources":[{"listingId":"1e6b4a73-81a0-4b7b-94d4-e363925f56b5","source":"pulsemcp","sourceId":"https://www.pulsemcp.com/servers/gh-aguantar-kafka-dataops","sourceUrl":"https://api.pulsemcp.com/v0beta/servers","isPrimary":true,"firstSeenAt":"2026-04-25T08:30:05.696Z","lastSeenAt":"2026-05-15T05:22:22.184Z"}],"details":{"listingId":"1e6b4a73-81a0-4b7b-94d4-e363925f56b5","quickStartSnippet":null,"exampleRequest":null,"exampleResponse":null,"schema":null,"openapiUrl":null,"agentsTxtUrl":null,"citations":[],"useCases":[],"bestFor":[],"notFor":[],"kindDetails":{"source":"pulsemcp","transport":"stdio","server_name":"Kafka DataOps","external_url":"https://github.com/Aguantar/kafka-mcp-server","github_stars":0,"registry_url":"https://www.pulsemcp.com/servers/gh-aguantar-kafka-dataops","source_code_url":"https://github.com/aguantar/kafka-mcp-server"},"updatedAt":"2026-05-15T05:22:22.184Z"}}