1. Conduid
  2. Data
  3. Kafka MCP Server Sbai
MCP server · Data

Kafka MCP Server Sbai

by · github.com/zakariahere/kafka-mcp-server-sbai

Kafka mcp server built with spring boot ai

Unclaimed last commit 8 months ago data
InstallView source
34Low

Scored 6 months ago · breakdown

About Kafka MCP Server Sbai

Kafka MCP Server Sbai is an MCP server published by zakariahere in the Data category: kafka mcp server built with spring boot ai.

The repository has 1 stars and 0 forks, with the last commit 8 months ago. Six months or more without a commit doesn't mean the server is broken, but check the open issues before depending on it in production.

Install

From source
git clone https://github.com/zakariahere/kafka-mcp-server-sbai

This server has no ConduID identity, so agent calls to it are not receipted. Pin the version you install and review the source before granting it credentials.

Tools (4)

createTopicCreates a topic with a specified partition count and replication factor

Parameters not published.

deleteTopicPermanently deletes a topic and all its messages

Parameters not published.

describeTopicReturns partition layout, replicas, ISR, and non-default config for a topic

Parameters not published.

listTopicsLists all topics in the cluster

Parameters not published.

Ask AI

✦

Ask AI about Kafka MCP Server Sbai

Powered by Claude · Grounded in docs

I know everything about Kafka MCP Server Sbai. Ask me about installation, configuration, usage, or troubleshooting.

Security checks

  • ✓README presentThe repository ships documentation.

5 checks have not been run yet.

README

kafka-mcp-sbai

A Kafka MCP (Model Context Protocol) server built with Spring Boot and Spring AI. Exposes Kafka cluster operations as tools consumable by AI clients over the MCP protocol via SSE transport.

Tech Stack

Component Version
Java 25
Spring Boot 4.0.2
Spring AI 2.0.0-M2
Apache Kafka via spring-boot-starter-kafka
Build Maven (wrapper scripts included)

Prerequisites

  • Java 25+
  • Docker (for the local Kafka broker)

Quick Start

# Build
mvnw.cmd clean package -DskipTests          # Windows
./mvnw clean package -DskipTests            # Unix

# Run
mvnw.cmd spring-boot:run                    # Windows
./mvnw spring-boot:run                      # Unix

Spring Boot's Docker Compose integration automatically starts the Kafka broker, Schema Registry, and Kafka UI defined in compose.yaml when the application launches. No manual docker compose up is needed.

The MCP server starts on port 9085.

Local Infrastructure (compose.yaml)

Service Port Description
Kafka (KRaft) 9092 Single-node broker, auto-creates topics
Schema Registry 8081 Confluent Schema Registry
Kafka UI 8080 Provectus Kafka UI for cluster management

Exposed MCP Tools

Topic Management

Tool Description
listTopics Lists all topics in the cluster
describeTopic Returns partition layout, replicas, ISR, and non-default config for a topic
createTopic Creates a topic with a specified partition count and replication factor
deleteTopic Permanently deletes a topic and all its messages

Messaging

Tool Parameters Description
produceMessage topic, message, key?, headers? Publishes a message; returns partition and offset
consumeMessages topic, maxMessages?, fromBeginning?, timeoutSeconds? Reads messages via a short-lived consumer group
peekMessages topic, partition, offset, count? Reads from a specific partition/offset without committing

Consumer Groups

Tool Description
listConsumerGroups Lists all consumer group IDs
describeConsumerGroup Returns group state, coordinator, members, and partition assignments

Cluster

Tool Description
describeCluster Returns cluster ID, controller, and all broker details

Architecture

AI Client  ──SSE──>  MCP Server (port 9085)
                          │
                    ┌─────▼──────┐
                    │ToolProvider │   @Tool-annotated methods, auto-registered
                    └─────┬──────┘      by Spring AI's MethodToolCallbackProvider
                          │
                    ┌─────▼──────┐
                    │KafkaService │   Wraps AdminClient, KafkaTemplate,
                    └─────┬──────┘   and ad-hoc KafkaConsumer instances
                          │
                    ┌─────▼──────┐
                    │   Kafka     │   Local broker via Docker Compose
                    └────────────┘
  • No REST layer. MCP over SSE is the sole transport.
  • McpMessageStatusFilter patches the /mcp/message POST response from 200 OK to 202 Accepted to satisfy Claude's SSE expectations.
  • Consumer operations (consumeMessages, peekMessages) spin up ephemeral KafkaConsumer instances with unique group IDs so they don't interfere with application consumers.

Configuration

Key properties in application.properties:

server.port=9085
spring.ai.mcp.server.transport=sse
spring.ai.mcp.server.sse-endpoint=/sse
spring.ai.mcp.server.sse-message-endpoint=/mcp/message
spring.kafka.bootstrap-servers=localhost:9092

Testing

# Full test suite
mvnw.cmd test

# Single test class
mvnw.cmd test -Dtest=com.elzakaria.kafkamcpsbai.SomeTestClass

# Single test method
mvnw.cmd test -Dtest="com.elzakaria.kafkamcpsbai.SomeTestClass#methodName"

README copy captured when this server was indexed; it may lag the repository. The original is authoritative.

Questions

About Kafka MCP Server Sbai

How do I install Kafka MCP Server Sbai?

No package has been published for this server, so install it from source: clone the repository and follow its README.

Is Kafka MCP Server Sbai safe to use with an AI agent?

Its trust score is 34 out of 100 (low). It passes 1 of the 1 static security checks run so far. It has no ConduID identity yet, so agent calls to it are not receipted.

Is Kafka MCP Server Sbai still maintained?

The last commit was 8 months ago. That's long enough that you should check whether the maintainer is responding to issues before depending on it.