Supports environment variable configuration through .env files for Kafka connection settings and tool descriptions.
Provides publish and consume functionalities for Kafka topics, allowing messages to be sent to and retrieved from Kafka streams. Messages consumed cannot be read again using the same group ID.
Utilizes Pydantic for settings management and validation of configuration values.
Ein Message Context Protocol (MCP)-Server, der in Apache Kafka integriert ist, um Veröffentlichungs- und Konsumfunktionen für LLM- und Agentic-Anwendungen bereitzustellen.
Dieses Projekt implementiert einen Server, der es KI-Modellen ermöglicht, über eine standardisierte Schnittstelle mit Kafka-Themen zu interagieren. Es unterstützt:
Erstellen Sie im Projektstammverzeichnis eine .env Datei mit den folgenden Variablen:
Sie können den Server mit dem bereitgestellten main.py -Skript ausführen:
Verfügbare Transportmöglichkeiten:
stdio : Standardeingabe/-ausgabe (Standard)sse : Vom Server gesendete EreignisseUm diesen Kafka MCP-Server mit Claude Desktop zu verwenden, fügen Sie Ihrer Claude Desktop-Konfigurationsdatei die folgende Konfiguration hinzu:
Ersetzen Sie <PATH TO PROJECTS> durch den absoluten Pfad zu Ihrem Projektverzeichnis.
main.py : Einstiegspunkt für die Anwendungkafka.py : Implementierung des Kafka-Konnektorsserver.py : MCP-Serverimplementierung mit Tools für die Kafka-Interaktionsettings.py : Konfigurationsverwaltung mit PydanticVeröffentlicht Informationen zum konfigurierten Kafka-Thema.
Informationen aus dem konfigurierten Kafka-Thema nutzen.
This server cannot be installed
remote-capable server
The server can be hosted and run remotely because it primarily relies on remote services or has no dependency on the local environment.
Ermöglicht KI-Modellen, Nachrichten aus Apache Kafka-Themen über eine standardisierte Schnittstelle zu veröffentlichen und zu nutzen, wodurch die Integration von Kafka-Messaging in LLM- und Agent-Anwendungen vereinfacht wird.