広告掲載
MCP.so
ログイン

MCP Kafka Processor

@boufnichel

リポジトリ

基本情報

カテゴリ

生産性

トランスポート

stdio

作者

boufnichel

MCP Kafka Processor について

An MCP server for processing Kafka events and enabling LLMs to interact with event streams

#mcp-kafka-processor#kafka-events#llm-integration

MCP Kafka Processor の設定

標準の設定はありません

このサーバーの README には解析可能な MCP 設定ブロックが含まれていません。インストール手順はリポジトリをご確認ください。

リポジトリ

MCP Kafka Processor のツール

ツール一覧はまだありません

この掲載には表示できるツール一覧がまだありません。サーバーにツールがないという意味ではありません。対応機能はプロジェクトのドキュメントをご確認ください。

ツールは README から自動的に抽出されます。メンテナーは ## Tools という見出しの下に記載することで、このタブに反映できます。

概要

What is Mcp Kafka Processor?

Mcp Kafka Processor is an MCP server that provides event processing capabilities through Kafka integration. It allows Large Language Models to interact with Kafka topics through the Model Context Protocol, enabling publish and consume operations for event-driven AI workflows.

How to use Mcp Kafka Processor?

Clone the repository, install dependencies with npm install, and build with npm run build. Configure the Kafka broker using the KAFKA_BROKERS environment variable (default localhost:9092), then add the server to your Claude Desktop configuration by specifying the build/index.js path and environment variable in claude_desktop_config.json.

Key features of Mcp Kafka Processor

  • Publish events to Kafka topics
  • Consume events from Kafka topics
  • Easy integration with Claude Desktop and MCP clients
  • Type-safe implementation using TypeScript
  • Configurable via environment variables

Use cases of Mcp Kafka Processor

  • Publishing messages from an LLM to a Kafka topic for downstream processing
  • Consuming Kafka events and delivering them to an AI assistant for analysis
  • Automating event-driven workflows with AI as the decision engine
  • Enabling real-time data pipelines where AI consumes or produces Kafka messages

よくある質問

1

What is the purpose of this server?

It enables LLMs to publish and consume events from Kafka topics through the MCP protocol, bridging AI agents with Kafka-based event streams.

2

What are the prerequisites for using it?

Node.js 16 or higher, an accessible Kafka broker, and TypeScript knowledge for development.

3

How do I configure the Kafka broker connection?

Set the `KAFKA_BROKERS` environment variable to a comma-separated list of broker addresses (default is `localhost:9092`).

4

What tools does the server provide?

Two tools: `publish-event` (send a message to a topic) and `consume-events` (receive messages from a topic). Both require a `topic` parameter; consume-events also accepts an optional `maxMessages` parameter.

5

Can I limit how many messages are consumed?

Yes, the `consume-events` tool has a `maxMessages` parameter that defaults to 10.

コメント

「生産性」の他のコンテンツ

fynk

fynk

Draft, find, negotiate, analyze and sign contracts in fynk. Create documents via AI, from templates or PDFs, manage parties, signatories and fields, and send for e-signature, all with your own fynk permissions via OAuth.

One

One

Connect your agent to the apps your team already uses: Gmail, Slack, Stripe, Shopify, HubSpot, Notion, Linear, Salesforce, QuickBooks and more. One hosted MCP server with OAuth sign-in, nothing to install and no API keys

BoardMark

I C Develop Co., Ltd

Plan and track your team's work in BoardMark from any AI agent: find, create and move issues, run Scrum sprints, comment and keep project docs current. OAuth sign-in, your own permissions.

Q

QuillHub

QuillHub

Meeting transcripts for AI agents: search every call, read who said what, pull decisions and action items, get quotes from one person across meetings, follow deals and projects, and transcribe files or YouTube links. Hos

WhatsMCP

whatsmcp

WhatsMCP — WhatsApp for AI agents. Put an AI agent on a real WhatsApp number. Expose regular WhatsApp accounts to your LLM agents over JSON-RPC. A complete Model Context Protocol server that turns phone numbers into addr

広告掲載