{"_id":"@dockndevai/mcp-kafka","_rev":"8-85e99c1b069bbc19acc189b1ee71e007","name":"@dockndevai/mcp-kafka","dist-tags":{"latest":"0.3.0"},"versions":{"0.1.0":{"name":"@dockndevai/mcp-kafka","version":"0.1.0","keywords":["mcp","model-context-protocol","kafka","apache-kafka","devops","observability","llm","ai"],"license":"MIT","_id":"@dockndevai/mcp-kafka@0.1.0","maintainers":[{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"}],"homepage":"https://github.com/dockndevai/mcp-kafka#readme","bugs":{"url":"https://github.com/dockndevai/mcp-kafka/issues"},"bin":{"mcp-kafka":"dist/index.js"},"dist":{"shasum":"1bb21c13661cab6c4176225f99f27a653099f3dc","tarball":"https://registry.npmjs.org/@dockndevai/mcp-kafka/-/mcp-kafka-0.1.0.tgz","fileCount":30,"integrity":"sha512-t5DKOyWow4RdG5PclKu+1S8wmADMwRHaChMcZO6k+VsVMw1kVPnMEl7YfgcBgTGP4iaDzPh5vFAkAN/jyRy4wg==","signatures":[{"sig":"MEUCIQCmwMTHmraqX2KPZ9gD9t5Vqz0K/BSCRqpjJ61m+9MRhwIgP6MJBeKONtvYkuX6atorLmGBQZ9WRKB4VsKtF0HWaQ0=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@dockndevai%2fmcp-kafka@0.1.0","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":58085},"type":"module","engines":{"node":">=20"},"gitHead":"0248eeb7fb7ad9175071d09d4066c359c1a5b3d0","mcpName":"io.github.dockndevai/mcp-kafka","scripts":{"dev":"tsx watch src/index.ts","lint":"tsc -p tsconfig.json --noEmit","test":"vitest run","build":"tsc -p tsconfig.json","start":"node dist/index.js","typecheck":"tsc -p tsconfig.json --noEmit","test:watch":"vitest","prepublishOnly":"npm run build"},"_npmUser":{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"},"repository":{"url":"git+https://github.com/dockndevai/mcp-kafka.git","type":"git"},"_npmVersion":"10.8.2","description":"Model Context Protocol server for Apache Kafka — monitor and manage clusters, topics, and consumer groups with security modes and access-control flags.","directories":{},"_nodeVersion":"20.20.2","dependencies":{"zod":"^3.23.8","kafkajs":"^2.2.4","@modelcontextprotocol/sdk":"^1.12.0"},"_hasShrinkwrap":false,"devDependencies":{"tsx":"^4.19.2","vitest":"^3.2.7","typescript":"^5.6.3","@types/node":"^22.9.0"},"_npmOperationalInternal":{"tmp":"tmp/mcp-kafka_0.1.0_1787471366262_0.4043568189811273","host":"s3://npm-registry-packages-npm-production"}},"0.1.1":{"name":"@dockndevai/mcp-kafka","version":"0.1.1","keywords":["mcp","model-context-protocol","kafka","apache-kafka","devops","observability","llm","ai"],"license":"MIT","_id":"@dockndevai/mcp-kafka@0.1.1","maintainers":[{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"}],"homepage":"https://github.com/dockndevai/mcp-kafka#readme","bugs":{"url":"https://github.com/dockndevai/mcp-kafka/issues"},"bin":{"mcp-kafka":"dist/index.js"},"dist":{"shasum":"59fefd55598220a73abd4ec11f1d9b6820cd6451","tarball":"https://registry.npmjs.org/@dockndevai/mcp-kafka/-/mcp-kafka-0.1.1.tgz","fileCount":33,"integrity":"sha512-p0NGIFLGUhIvOxN5BtGfBXV3S9uwdiY9OY7PpCfdEronEmH/fMAAHdJjrOGwq3oVAlhRM7aQxhxCtSKbbS/YAQ==","signatures":[{"sig":"MEQCIHZ9McJ0Xxect3Kbr+gCOs0H9kHeVPtnMdj91l6S2bAbAiBSIJ/JU5Z4iRPDzR5OTJpiT2rEHskDC8Hcru5NB20jFg==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@dockndevai%2fmcp-kafka@0.1.1","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":62384},"type":"module","engines":{"node":">=20"},"gitHead":"07749ad76bab6393e2aa10b039e5d943cd1dcb42","mcpName":"io.github.dockndevai/mcp-kafka","scripts":{"dev":"tsx watch src/index.ts","lint":"tsc -p tsconfig.json --noEmit","test":"vitest run","build":"tsc -p tsconfig.json","start":"node dist/index.js","typecheck":"tsc -p tsconfig.json --noEmit","test:watch":"vitest","prepublishOnly":"npm run build"},"_npmUser":{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"},"repository":{"url":"git+https://github.com/dockndevai/mcp-kafka.git","type":"git"},"_npmVersion":"10.8.2","description":"Model Context Protocol server for Apache Kafka — monitor and manage clusters, topics, and consumer groups with security modes and access-control flags.","directories":{},"_nodeVersion":"20.20.2","dependencies":{"zod":"^3.23.8","kafkajs":"^2.2.4","@modelcontextprotocol/sdk":"^1.12.0"},"_hasShrinkwrap":false,"devDependencies":{"tsx":"^4.19.2","vitest":"^3.2.7","typescript":"^5.6.3","@types/node":"^22.9.0"},"_npmOperationalInternal":{"tmp":"tmp/mcp-kafka_0.1.1_1787885432868_0.487726092414273","host":"s3://npm-registry-packages-npm-production"}},"0.1.2":{"name":"@dockndevai/mcp-kafka","version":"0.1.2","keywords":["mcp","model-context-protocol","kafka","apache-kafka","devops","observability","llm","ai"],"license":"MIT","_id":"@dockndevai/mcp-kafka@0.1.2","maintainers":[{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"}],"homepage":"https://github.com/dockndevai/mcp-kafka#readme","bugs":{"url":"https://github.com/dockndevai/mcp-kafka/issues"},"bin":{"mcp-kafka":"dist/index.js"},"dist":{"shasum":"213c11d29fb459ec143a488c269884da18e61414","tarball":"https://registry.npmjs.org/@dockndevai/mcp-kafka/-/mcp-kafka-0.1.2.tgz","fileCount":33,"integrity":"sha512-iYfkGdxXi4pFoG+wNXclMNvKRRyvZNw456T+OvVxWOfwBpdb9udq0oGhQ2/HYxkRFT5NnSdvOV5+DyMSZjedAw==","signatures":[{"sig":"MEYCIQD24nRHfV3xQz2JCE8gtfL7X+21F6PkUS0eRYdcLhK2GwIhAMSp5K90uecdVbr3tzogGCXD3qV86OY0qXv1b4X5zWqn","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@dockndevai%2fmcp-kafka@0.1.2","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":62384},"type":"module","engines":{"node":">=20"},"gitHead":"c7ab37134972bb06bf0416677dfa4282a0be0bb5","mcpName":"io.github.dockndevai/mcp-kafka","scripts":{"dev":"tsx watch src/index.ts","lint":"tsc -p tsconfig.json --noEmit","test":"vitest run","build":"tsc -p tsconfig.json","start":"node dist/index.js","typecheck":"tsc -p tsconfig.json --noEmit","test:watch":"vitest","prepublishOnly":"npm run build"},"_npmUser":{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"},"repository":{"url":"git+https://github.com/dockndevai/mcp-kafka.git","type":"git"},"_npmVersion":"10.8.2","description":"Model Context Protocol server for Apache Kafka — monitor and manage clusters, topics, and consumer groups with security modes and access-control flags.","directories":{},"_nodeVersion":"20.20.2","dependencies":{"zod":"^3.23.8","kafkajs":"^2.2.4","@modelcontextprotocol/sdk":"^1.30.0"},"_hasShrinkwrap":false,"devDependencies":{"tsx":"^4.19.2","vitest":"^3.2.7","typescript":"^5.6.3","@types/node":"^22.9.0"},"_npmOperationalInternal":{"tmp":"tmp/mcp-kafka_0.1.2_1788070713788_0.9839112273972026","host":"s3://npm-registry-packages-npm-production"}},"0.1.3":{"name":"@dockndevai/mcp-kafka","version":"0.1.3","keywords":["mcp","model-context-protocol","kafka","apache-kafka","devops","observability","llm","ai"],"license":"MIT","_id":"@dockndevai/mcp-kafka@0.1.3","maintainers":[{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"}],"homepage":"https://github.com/dockndevai/mcp-kafka#readme","bugs":{"url":"https://github.com/dockndevai/mcp-kafka/issues"},"bin":{"mcp-kafka":"dist/index.js"},"dist":{"shasum":"e7d313695dd30109f9381f5c54028b46d4e1d285","tarball":"https://registry.npmjs.org/@dockndevai/mcp-kafka/-/mcp-kafka-0.1.3.tgz","fileCount":33,"integrity":"sha512-AK88Y2sbfwJ1XvvWGXUGwN++Y5i5NmlGo6n42nM6rVRS/v49w6XA9hr8vvVx1gG0oHWBAIVVepIgvM5xCd99AQ==","signatures":[{"sig":"MEQCIFqFe5j/aNe/l4UuS0ed/xEhvPepcMv19k/nEjA/59/OAiAm82jlnwAGphcwXtXYC+FjTktVXjUrCA9tltWRwvIYDw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEUCIDBdPESyg4vRFTLa035fUt6zuQlHtDqvRVpry6vsCyiWAiEAvfIp6hco4g/A9Wmb/HzZrQdoguLk4mTumvg39V4nl/s=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@dockndevai%2fmcp-kafka@0.1.3","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":62384},"type":"module","engines":{"node":">=22"},"gitHead":"c9ff160ff5b9bef79f000ac47137409a136b2936","mcpName":"io.github.dockndevai/mcp-kafka","scripts":{"dev":"tsx watch src/index.ts","lint":"tsc -p tsconfig.json --noEmit","test":"vitest run","build":"tsc -p tsconfig.json","start":"node dist/index.js","typecheck":"tsc -p tsconfig.json --noEmit","test:watch":"vitest","prepublishOnly":"npm run build"},"_npmUser":{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"},"repository":{"url":"git+https://github.com/dockndevai/mcp-kafka.git","type":"git"},"_npmVersion":"10.9.8","description":"Model Context Protocol server for Apache Kafka — monitor and manage clusters, topics, and consumer groups with security modes and access-control flags.","directories":{},"_nodeVersion":"22.23.2","dependencies":{"zod":"^3.23.8","kafkajs":"^2.2.4","@modelcontextprotocol/sdk":"^1.30.0"},"_hasShrinkwrap":false,"devDependencies":{"tsx":"^4.19.2","vitest":"^5.0.0","typescript":"^5.6.3","@types/node":"^22.9.0"},"_npmOperationalInternal":{"tmp":"tmp/mcp-kafka_0.1.3_1788969506627_0.8284803577319324","host":"s3://npm-registry-packages-npm-production"}},"0.2.0":{"name":"@dockndevai/mcp-kafka","version":"0.2.0","keywords":["mcp","model-context-protocol","kafka","apache-kafka","devops","observability","llm","ai"],"license":"MIT","_id":"@dockndevai/mcp-kafka@0.2.0","maintainers":[{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"}],"homepage":"https://github.com/dockndevai/mcp-kafka#readme","bugs":{"url":"https://github.com/dockndevai/mcp-kafka/issues"},"bin":{"mcp-kafka":"dist/index.js"},"dist":{"shasum":"6be665df0d93ed88b222ac72044240bdabac3189","tarball":"https://registry.npmjs.org/@dockndevai/mcp-kafka/-/mcp-kafka-0.2.0.tgz","fileCount":36,"integrity":"sha512-Hi9VQhU37lwt37Ee7XxyqTfVJMqJegjIZHe99guvf9q3XmS/U0plYM54pHLEyOspBAOIgDan36yiI7bm2EvqVA==","signatures":[{"sig":"MEYCIQDfLVV7Kx0awrM8QxiPjTk7tbu0rt+UD0+mYsE6l77TMQIhAOemFOs4kEceXSrRU4KQ/F7/3hD9d+CTzcxe52I8pziT","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEUCIDTIRqjFV+9KATTJo5hV7aQdYYKUZB0d2+P+cMrVI696AiEAmhLVuPbx+c9Bo7662N3/ELr3wYb2GChDnszGePTup7w=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@dockndevai%2fmcp-kafka@0.2.0","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":68901},"type":"module","engines":{"node":">=22"},"gitHead":"219483cf72ddc51e712c71dff38c26ec633a8ec9","mcpName":"io.github.dockndevai/mcp-kafka","scripts":{"dev":"tsx watch src/index.ts","lint":"tsc -p tsconfig.json --noEmit","test":"vitest run","build":"tsc -p tsconfig.json","start":"node dist/index.js","typecheck":"tsc -p tsconfig.json --noEmit","test:watch":"vitest","prepublishOnly":"npm run build"},"_npmUser":{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"},"repository":{"url":"git+https://github.com/dockndevai/mcp-kafka.git","type":"git"},"_npmVersion":"10.9.8","description":"Model Context Protocol server for Apache Kafka — monitor and manage clusters, topics, and consumer groups with security modes and access-control flags.","directories":{},"_nodeVersion":"22.23.2","dependencies":{"zod":"^3.23.8","kafkajs":"^2.2.4","@modelcontextprotocol/sdk":"^1.30.0"},"_hasShrinkwrap":false,"devDependencies":{"tsx":"^4.19.2","vitest":"^5.0.0","typescript":"^5.6.3","@types/node":"^22.9.0"},"_npmOperationalInternal":{"tmp":"tmp/mcp-kafka_0.2.0_1788981969283_0.8305971199075477","host":"s3://npm-registry-packages-npm-production"}},"0.2.1":{"name":"@dockndevai/mcp-kafka","version":"0.2.1","keywords":["mcp","model-context-protocol","kafka","apache-kafka","devops","observability","llm","ai"],"license":"MIT","_id":"@dockndevai/mcp-kafka@0.2.1","maintainers":[{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"}],"homepage":"https://github.com/dockndevai/mcp-kafka#readme","bugs":{"url":"https://github.com/dockndevai/mcp-kafka/issues"},"bin":{"mcp-kafka":"dist/index.js"},"dist":{"shasum":"104f07efa51fd3f64ace35e76478ede4c084da3f","tarball":"https://registry.npmjs.org/@dockndevai/mcp-kafka/-/mcp-kafka-0.2.1.tgz","fileCount":36,"integrity":"sha512-HRHXHlxLgcX+CAkyDpdMq9RU8FIo7wdZzmj4j6yELYxw9xlGJS6CSCC8jbBB72rXEd6eWUkckMXIJDeRIm0yYQ==","signatures":[{"sig":"MEYCIQDE0+D1ks1zQllLatj+c4qZASjFSUu/CVIQYGfnNMNMxwIhAL1ZEEMLhLQ5cvavSiIDNcZo219+3leAimPTg7KSNW4o","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEQCIEh6z9HjeJ4EYF0PFAwLPFVkFlCCEqn9TkVcFN5uCZbSAiB/htCCF+mC4ajWaNkVBxFNveEfxLDtwu5BYnvvFViTfQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@dockndevai%2fmcp-kafka@0.2.1","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":69649},"type":"module","engines":{"node":">=22"},"gitHead":"62c500023f495cbe6f8aef564be37b01cf7f8ff6","mcpName":"io.github.dockndevai/mcp-kafka","scripts":{"dev":"tsx watch src/index.ts","lint":"tsc -p tsconfig.json --noEmit","test":"vitest run","build":"tsc -p tsconfig.json","start":"node dist/index.js","typecheck":"tsc -p tsconfig.json --noEmit","test:watch":"vitest","prepublishOnly":"npm run build"},"_npmUser":{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"},"repository":{"url":"git+https://github.com/dockndevai/mcp-kafka.git","type":"git"},"_npmVersion":"10.9.8","description":"Model Context Protocol server for Apache Kafka — monitor and manage clusters, topics, and consumer groups with security modes and access-control flags.","directories":{},"_nodeVersion":"22.23.2","dependencies":{"zod":"^3.23.8","kafkajs":"^2.2.4","@modelcontextprotocol/sdk":"^1.30.0"},"_hasShrinkwrap":false,"devDependencies":{"tsx":"^4.19.2","vitest":"^5.0.0","typescript":"^5.6.3","@types/node":"^22.9.0"},"_npmOperationalInternal":{"tmp":"tmp/mcp-kafka_0.2.1_1788983271691_0.8456449146494855","host":"s3://npm-registry-packages-npm-production"}},"0.2.2":{"name":"@dockndevai/mcp-kafka","version":"0.2.2","keywords":["mcp","model-context-protocol","kafka","apache-kafka","devops","observability","llm","ai"],"license":"MIT","_id":"@dockndevai/mcp-kafka@0.2.2","maintainers":[{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"}],"homepage":"https://github.com/dockndevai/mcp-kafka#readme","bugs":{"url":"https://github.com/dockndevai/mcp-kafka/issues"},"bin":{"mcp-kafka":"dist/index.js"},"dist":{"shasum":"4617840d982b4af79f5a8ad45555d12015e8da04","tarball":"https://registry.npmjs.org/@dockndevai/mcp-kafka/-/mcp-kafka-0.2.2.tgz","fileCount":36,"integrity":"sha512-h+fsjwJveBh6wCU3+UYNW9PTL2Rx2yRG0MpH2NWPcE9tnkt+pi3guRXEKXKbwXKSKTtCOIQeSg0BPW+SJsaCsA==","signatures":[{"sig":"MEUCIQDpulTdim6SeKOP6lNYDajdvt/ZqpJU4ATXd2vs5jjhdwIgOzCpwuWIiYUBo7KtUaqp4N619RlCAmuc6nikAXxLooY=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEUCIDiVWAYCdvC6b9FO07FTgyxkdqKQKNFjfKGlxBsLWvJPAiEAuOfZGaFfqMiF+hnTosxETGrOw2t+MkplbrBSYae8950=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@dockndevai%2fmcp-kafka@0.2.2","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":69714},"type":"module","engines":{"node":">=22"},"gitHead":"04723b8bde360994de1efbe6f3ab4045c57c073d","mcpName":"io.github.dockndevai/mcp-kafka","scripts":{"dev":"tsx watch src/index.ts","lint":"tsc -p tsconfig.json --noEmit","test":"vitest run","build":"tsc -p tsconfig.json","start":"node dist/index.js","typecheck":"tsc -p tsconfig.json --noEmit","test:watch":"vitest","prepublishOnly":"npm run build"},"_npmUser":{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"},"repository":{"url":"git+https://github.com/dockndevai/mcp-kafka.git","type":"git"},"_npmVersion":"10.9.8","description":"Model Context Protocol server for Apache Kafka — monitor and manage clusters, topics, and consumer groups with security modes and access-control flags.","directories":{},"_nodeVersion":"22.23.2","dependencies":{"zod":"^4.5.4","kafkajs":"^2.2.4","@modelcontextprotocol/sdk":"^1.30.0"},"_hasShrinkwrap":false,"devDependencies":{"tsx":"^4.23.13","vitest":"^5.0.0","typescript":"^7.0.2","@types/node":"^26.5.0"},"_npmOperationalInternal":{"tmp":"tmp/mcp-kafka_0.2.2_1789235904329_0.6561698400354747","host":"s3://npm-registry-packages-npm-production"}},"0.3.0":{"_id":"@dockndevai/mcp-kafka@0.3.0","bin":{"mcp-kafka":"dist/index.js"},"bugs":{"url":"https://github.com/dockndevai/mcp-kafka/issues"},"dist":{"shasum":"ceab1d3f227160b683c5d81c21ae72248f629be5","tarball":"https://registry.npmjs.org/@dockndevai/mcp-kafka/-/mcp-kafka-0.3.0.tgz","fileCount":39,"integrity":"sha512-Oauh/81hviq51uvf7PT/Y7rvBFKhtOO6fn1/h8Czbok2Cn0wQSx8wjxyz1EI4OvyYwJVGFqp0e013RfnlsUqnQ==","signatures":[{"sig":"MEYCIQC//kcUo1IkQA5heigNE3Fa+WRe2ZHzfutzyWM2wE5Z1wIhANJgAiT9zj8d2/B4CcXoCvuluAm8JrYMh7lhCfrXcC1D","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEUCIQD/7LBBDbC9Tu60h5PdY82HJEnSR5gisIpjepN/eb6xFAIgc9W8c4uuNnhEa71jh5HwmtxeWDydrkibTMfHyJumSUo="}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@dockndevai%2fmcp-kafka@0.3.0","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":79717},"name":"@dockndevai/mcp-kafka","type":"module","engines":{"node":">=22"},"gitHead":"54295a95a32933e846181cf57cfe97ec5570c8e6","license":"MIT","mcpName":"io.github.dockndevai/mcp-kafka","scripts":{"dev":"tsx watch src/index.ts","lint":"tsc -p tsconfig.json --noEmit","test":"vitest run","build":"tsc -p tsconfig.json","start":"node dist/index.js","typecheck":"tsc -p tsconfig.json --noEmit","test:watch":"vitest","prepublishOnly":"npm run build"},"version":"0.3.0","_npmUser":{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"},"homepage":"https://github.com/dockndevai/mcp-kafka#readme","keywords":["mcp","model-context-protocol","kafka","apache-kafka","devops","observability","llm","ai"],"repository":{"url":"git+https://github.com/dockndevai/mcp-kafka.git","type":"git"},"_npmVersion":"10.9.8","description":"Model Context Protocol server for Apache Kafka — monitor and manage clusters, topics, and consumer groups with security modes and access-control flags.","directories":{},"maintainers":[{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"}],"_nodeVersion":"22.23.2","dependencies":{"zod":"^4.5.4","kafkajs":"^2.2.4","@modelcontextprotocol/sdk":"^1.30.0"},"_hasShrinkwrap":false,"devDependencies":{"tsx":"^4.23.13","vitest":"^5.0.0","typescript":"^7.0.2","@types/node":"^26.5.0"},"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/mcp-kafka_0.3.0_1790685037262_0.4969710349568184"}}},"time":{"created":"2026-08-23T07:49:26.121Z","modified":"2026-09-29T12:30:37.667Z","0.1.0":"2026-08-23T07:49:26.394Z","0.1.1":"2026-08-28T02:50:33.013Z","0.1.2":"2026-08-30T06:18:33.914Z","0.1.3":"2026-09-09T15:58:26.712Z","0.2.0":"2026-09-09T19:26:09.373Z","0.2.1":"2026-09-09T19:47:51.805Z","0.2.2":"2026-09-12T17:58:24.420Z","0.3.0":"2026-09-29T12:30:37.343Z"},"bugs":{"url":"https://github.com/dockndevai/mcp-kafka/issues"},"license":"MIT","homepage":"https://github.com/dockndevai/mcp-kafka#readme","keywords":["mcp","model-context-protocol","kafka","apache-kafka","devops","observability","llm","ai"],"repository":{"url":"git+https://github.com/dockndevai/mcp-kafka.git","type":"git"},"description":"Model Context Protocol server for Apache Kafka — monitor and manage clusters, topics, and consumer groups with security modes and access-control flags.","maintainers":[{"name":"dock-n-dev-ai","email":"ankitcs17071993@gmail.com"}],"readme":"# mcp-kafka\n\n[![CI](https://github.com/dockndevai/mcp-kafka/actions/workflows/ci.yml/badge.svg)](https://github.com/dockndevai/mcp-kafka/actions/workflows/ci.yml)\n[![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](./LICENSE)\n[![npm](https://img.shields.io/npm/v/@dockndevai/mcp-kafka)](https://www.npmjs.com/package/@dockndevai/mcp-kafka)\n\nA [Model Context Protocol](https://modelcontextprotocol.io) server for **Apache Kafka**. It lets an MCP-capable client (Claude Desktop, Claude Code, etc.) **monitor and manage** Kafka clusters — topics, partitions, configs, and consumer groups (including lag) — with behaviour controlled entirely by flags.\n\nSafe by default: it starts read-only, can be scoped to an allowlist of topics, protects internal/critical topics from mutation, and gates destructive operations behind an explicit opt-in.\n\n## Features\n\n- **Monitoring** — cluster/broker info, topic metadata and offsets, consumer groups, and **per-partition + total consumer lag**.\n- **Management** — create topics, add partitions, alter topic configs, reset group offsets; delete topics/groups (admin).\n- **Access modes** — `read-only` → `read-write` → `admin`, layered so a mode never exposes tools above its level.\n- **Security flags** — topic allowlist, protected/internal topics, delete gating, dry-run, and JSON audit logging (see below).\n- **Auth** — plaintext, TLS, and SASL (PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512).\n\n## Security model\n\n| Concern | Flag | Default | Effect |\n| --- | --- | --- | --- |\n| What can the server do? | `KAFKA_MODE` | `read-only` | `read-only` exposes only monitoring; `read-write` adds management; `admin` adds deletes. Tools above the mode are **never registered**. |\n| Which topics are in scope? | `KAFKA_TOPIC_ALLOWLIST` | *(all)* | When set, operations on other topics are refused. |\n| Protect internal topics | `KAFKA_PROTECT_INTERNAL_TOPICS` | `true` | Topics starting with `_` can be read but never mutated. |\n| Protect specific topics | `KAFKA_PROTECTED_TOPICS` | *(none)* | Additional read-only-forever topics. |\n| Can it delete? | `KAFKA_ALLOW_DELETE` | `false` | `delete_topic` / `delete_consumer_group` need this **and** admin mode. |\n| Preview without touching the cluster | `KAFKA_DRY_RUN` | `false` | Write/admin tools validate + log intent, then return. |\n| Audit trail | `KAFKA_AUDIT_LOG` | `true` | Emits a JSON line to stderr per guarded operation. |\n| Interactive confirmation | *(automatic)* | — | Destructive & high-impact actions prompt the human to approve via MCP elicitation before running; clients without elicitation fall back to the `*_ALLOW_*` gate. |\n\n## Tools\n\n**Read** (`read-only`+): `cluster_info`, `list_topics`, `describe_topic`, `topic_offsets`, `list_consumer_groups`, `describe_consumer_group` (with lag)\n\n**Write** (`read-write`+): `create_topic`, `create_partitions`, `alter_topic_config`, `reset_consumer_group_offsets`\n\n**Admin** (`admin`): `delete_topic`, `delete_consumer_group` (both need `KAFKA_ALLOW_DELETE`)\n\n## Quickstart — add to your agent\n\nPublished on npm as [`@dockndevai/mcp-kafka`](https://www.npmjs.com/package/@dockndevai/mcp-kafka). No clone or build needed — your MCP client runs it on demand with `npx`. **Start in `read-only` mode**; see [`.env.example`](.env.example) for every variable and [docs/CLIENTS.md](docs/CLIENTS.md) for the full per-client guide.\n\n**Claude Code** (CLI)\n\n```bash\nclaude mcp add kafka -e KAFKA_BROKERS=\"localhost:9092\" -e KAFKA_MODE=\"read-only\" -- npx -y @dockndevai/mcp-kafka\n```\n\n**Claude Desktop · Cursor · Windsurf** — same block in `claude_desktop_config.json`, `.cursor/mcp.json`, or `~/.codeium/windsurf/mcp_config.json`:\n\n```json\n{\n  \"mcpServers\": {\n    \"kafka\": {\n      \"command\": \"npx\",\n      \"args\": [\n        \"-y\",\n        \"@dockndevai/mcp-kafka\"\n      ],\n      \"env\": {\n        \"KAFKA_BROKERS\": \"localhost:9092\",\n        \"KAFKA_MODE\": \"read-only\"\n      }\n    }\n  }\n}\n```\n\n**OpenAI Codex CLI** — in `~/.codex/config.toml`:\n\n```toml\n[mcp_servers.kafka]\ncommand = \"npx\"\nargs = [\"-y\", \"@dockndevai/mcp-kafka\"]\nenv = { KAFKA_BROKERS = \"localhost:9092\", KAFKA_MODE = \"read-only\" }\n```\n\n**VS Code (GitHub Copilot, Agent mode)** — in `.vscode/mcp.json`:\n\n```json\n{\n  \"servers\": {\n    \"kafka\": {\n      \"type\": \"stdio\",\n      \"command\": \"npx\",\n      \"args\": [\n        \"-y\",\n        \"@dockndevai/mcp-kafka\"\n      ],\n      \"env\": {\n        \"KAFKA_BROKERS\": \"localhost:9092\",\n        \"KAFKA_MODE\": \"read-only\"\n      }\n    }\n  }\n}\n```\n\n## Example prompts\n\n- *\"Which consumer groups have the most lag right now?\"*\n- *\"Describe the `orders` topic and show its offsets.\"*\n- *\"Create a topic `events` with 6 partitions and 7-day retention.\"* (needs `read-write`)\n\n## Run from source (development)\n\nPrefer the published package above. To run from a clone:\n\n```bash\nnpm install\nnpm run build\nnode dist/index.js   # with the environment variables set\n```\n\n## Develop\n\n```bash\nnpm run dev\nnpm test\nnpm run typecheck\n```\n\n## Publishing\n\nThis server ships a [`server.json`](server.json) for the official MCP registry and an [`mcpName`](package.json) for npm ownership validation. See **[PUBLISHING.md](PUBLISHING.md)** for publishing to npm and listing on the MCP registry, Smithery, Glama, Cursor, and PulseMCP.\n\n## License\n\nMIT\n","readmeFilename":"README.md"}