streamnative-mcp-server and kafka-mcp-server
About streamnative-mcp-server
streamnative/streamnative-mcp-server
Developer-friendly MCP server bridging Kafka and Pulsar protocols—built with ❤️ by StreamNative for an agentic, streaming-first future.
Implements both stdio and SSE transport modes with multi-session support for per-user Pulsar authentication, enabling isolated connections through HTTP bearer tokens and LRU-cached sessions. Exposes comprehensive admin and client operations across Kafka (topics, Schema Registry, Connect) and Pulsar (tenants, functions, sources/sinks) alongside StreamNative Cloud cluster management via service account authentication. Built in Go with protocol version negotiation and supports Docker/Kubernetes deployment through Homebrew, binaries, or Helm charts.
About kafka-mcp-server
tuannvm/kafka-mcp-server
A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go.
Exposes Kafka operations through MCP's tools, resources, and prompts registries, enabling LLM clients to produce/consume messages, manage topics and consumer groups, and assess cluster health. Supports dual transport modes—stdio for local integration with Claude Desktop and Cursor, plus HTTP with OAuth 2.1 for remote access. Built on franz-go for Kafka communication and includes SASL/TLS authentication and pre-configured workflows for common operations.
Related comparisons
Scores updated daily from GitHub, PyPI, and npm data. How scores work