Mcp Kafka Processor について
Mcp Kafka Processor は、LLM が Kafka トピックへイベントを発行し、メッセージを消費できる TypeScript 製 MCP サーバーです。2 種類のツールを備え、Claude Desktop などの MCP クライアント向けに設定できます。
主な機能
- 01Kafka トピックへのメッセージ発行
- 02Kafka トピックからのメッセージ消費
- 03任意のメッセージキー
- 04環境変数による Kafka ブローカー設定
活用シーン
- 01Kafka トピックへのイベント発行
- 02トピックから指定数のメッセージを取得
MCP 対応
この MCP サーバーは、Claude Desktop などの MCP クライアントに Kafka の発行・消費ツールを提供します。
設定
ローカルサーバーの設定はどのクライアントでも共通です。コピーしてクライアントの MCP 設定ファイルに貼り付けてください。
このサーバーのパッケージやリモートエンドポイントはまだ取得できていません。プロジェクトの README の手順に従ってください。
ツール
ローカルサーバーのツールはマシン上で起動して初めて取得できます。メンテナーはまだツール一覧を提供していません。
README(原文)English
プロジェクトの README よりこの README の日本語訳はまだありません。以下は英語の原文です。日本語の紹介はページ上部をご覧ください。
IyBNQ1AgS2Fma2EgUHJvY2Vzc29yCgpBbiBNQ1Agc2VydmVyIGltcGxlbWVudGF0aW9uIHRoYXQgcHJvdmlkZXMgZXZlbnQgcHJvY2Vzc2luZyBjYXBhYmlsaXRpZXMgdGhyb3VnaCBLYWZrYSBpbnRlZ3JhdGlvbi4gVGhpcyBzZXJ2ZXIgYWxsb3dzIExhcmdlIExhbmd1YWdlIE1vZGVscyB0byBpbnRlcmFjdCB3aXRoIEthZmthIHRvcGljcyB0aHJvdWdoIHRoZSBNb2RlbCBDb250ZXh0IFByb3RvY29sLgoKIyMgRmVhdHVyZXMKCi0gUHVibGlzaCBldmVudHMgdG8gS2Fma2EgdG9waWNzCi0gQ29uc3VtZSBldmVudHMgZnJvbSBLYWZrYSB0b3BpY3MKLSBFYXN5IGludGVncmF0aW9uIHdpdGggQ2xhdWRlIERlc2t0b3AgYW5kIG90aGVyIE1DUCBjbGllbnRzCi0gVHlwZS1zYWZlIGltcGxlbWVudGF0aW9uIHVzaW5nIFR5cGVTY3JpcHQKCiMjIFByZXJlcXVpc2l0ZXMKCi0gTm9kZS5qcyAxNiBvciBoaWdoZXIKLSBLYWZrYSBicm9rZXIgYWNjZXNzaWJsZQotIFR5cGVTY3JpcHQga25vd2xlZGdlIGZvciBkZXZlbG9wbWVudAoKIyMgSW5zdGFsbGF0aW9uCgpgYGBiYXNoCiMgQ2xvbmUgdGhlIHJlcG9zaXRvcnkKZ2l0IGNsb25lIGh0dHBzOi8vZ2l0aHViLmNvbS9ib3VmbmljaGVsL21jcC1rYWZrYS1wcm9jZXNzb3IuZ2l0CmNkIG1jcC1rYWZrYS1wcm9jZXNzb3IKCiMgSW5zdGFsbCBkZXBlbmRlbmNpZXMKbnBtIGluc3RhbGwKCiMgQnVpbGQgdGhlIHByb2plY3QKbnBtIHJ1biBidWlsZApgYGAKCiMjIENvbmZpZ3VyYXRpb24KClRoZSBzZXJ2ZXIgY2FuIGJlIGNvbmZpZ3VyZWQgdXNpbmcgZW52aXJvbm1lbnQgdmFyaWFibGVzOgoKLSBgS0FGS0FfQlJPS0VSU2A6IENvbW1hLXNlcGFyYXRlZCBsaXN0IG9mIEthZmthIGJyb2tlcnMgKGRlZmF1bHQ6ICJsb2NhbGhvc3Q6OTA5MiIpCgojIyBVc2FnZSB3aXRoIENsYXVkZSBEZXNrdG9wCgpBZGQgdGhlIGZvbGxvd2luZyB0byB5b3VyIENsYXVkZSBEZXNrdG9wIGNvbmZpZ3VyYXRpb24gKGBjbGF1ZGVfZGVza3RvcF9jb25maWcuanNvbmApOgoKYGBganNvbgp7CiAgIm1jcFNlcnZlcnMiOiB7CiAgICAiZXZlbnQtcHJvY2Vzc29yIjogewogICAgICAiY29tbWFuZCI6ICJub2RlIiwKICAgICAgImFyZ3MiOiBbIi9hYnNvbHV0ZS9wYXRoL3RvL2J1aWxkL2luZGV4LmpzIl0sCiAgICAgICJlbnYiOiB7CiAgICAgICAgIktBRktBX0JST0tFUlMiOiAibG9jYWxob3N0OjkwOTIiCiAgICAgIH0KICAgIH0KICB9Cn0KYGBgCgojIyBBdmFpbGFibGUgVG9vbHMKCiMjIyBwdWJsaXNoLWV2ZW50CgpQdWJsaXNoZXMgYSBtZXNzYWdlIHRvIGEgc3BlY2lmaWVkIEthZmthIHRvcGljLgoKUGFyYW1ldGVyczoKLSBgdG9waWNgOiBUaGUgS2Fma2EgdG9waWMgdG8gcHVibGlzaCB0bwotIGBtZXNzYWdlYDogVGhlIG1lc3NhZ2UgY29udGVudCB0byBwdWJsaXNoCi0gYGtleWA6IE9wdGlvbmFsIG1lc3NhZ2Uga2V5CgojIyMgY29uc3VtZS1ldmVudHMKCkNvbnN1bWVzIG1lc3NhZ2VzIGZyb20gYSBzcGVjaWZpZWQgS2Fma2EgdG9waWMuCgpQYXJhbWV0ZXJzOgotIGB0b3BpY2A6IFRoZSBLYWZrYSB0b3BpYyB0byBjb25zdW1lIGZyb20KLSBgbWF4TWVzc2FnZXNgOiBNYXhpbXVtIG51bWJlciBvZiBtZXNzYWdlcyB0byBjb25zdW1lIChkZWZhdWx0OiAxMCkKCiMjIERldmVsb3BtZW50CgpgYGBiYXNoCiMgSW5zdGFsbCBkZXBlbmRlbmNpZXMKbnBtIGluc3RhbGwKCiMgQnVpbGQgdGhlIHByb2plY3QKbnBtIHJ1biBidWlsZAoKIyBTdGFydCB0aGUgc2VydmVyCm5wbSBzdGFydApgYGAKCiMjIExpY2Vuc2UKCk1JVA==
コメント
AI アプリケーションが外部のツールやデータソースに統一的な方法で接続するためのオープンなプロトコルです。クライアントはモデルとの対話を担い、MCP サーバーはツール・リソース・プロンプトテンプレートを提供します。標準メッセージでやり取りするため、1 つのサーバーを複数のクライアントで再利用できます。