mcp-kafka
mcp-kafkaは、AIアシスタントがApache Kafkaと直接対話できるようにするModel Context Protocol（MCP）サーバーです。このツールを使用することで、AIアシスタントはKafkaトピックやメッセージの作成、管理、操作を行うことができます。Kafkaクラスターとのインタラクションを簡素化し、メッセージの送受信を効率的に行えるため、開発者やデータエンジニアにとって非常に便利です。
GitHubスター
72
ユーザー評価
未評価
お気に入り
0
閲覧数
18
フォーク
0
イシュー
2
インストール方法
難易度
中級推定所要時間
10-20 分
必要な環境
Go 1.24 or higherA running Kafka cluster (default connection: localhost:9092)インストール方法
インストール方法
前提条件
Go: 1.24以上
Kafkaクラスター: 実行中（デフォルト接続: localhost:9092）
インストール手順
1. リポジトリのクローン
bash
git clone https://github.com/kanapuli/mcp-kafka.git
cd mcp-kafka
2. アプリケーションのビルド
bash
make build
3. 特定のプラットフォーム用にビルド（オプション）
bash
make build GOOS=darwin GOARCH=arm64
4. Claude Desktopツールとしてインストール
1上記の手順でアプリケーションをビルドします。
2実行可能ファイルをシステムのPATHに含まれる場所または専用のツールディレクトリに配置します。
3[Claude Desktop Tool Installation Guide](https://modelcontextprotocol.io/quickstart/user)に従ってツールをインストールします。
トラブルシューティング
問題: サーバーが起動しない 解決策: Goのバージョンを確認し、依存関係を再インストールしてください。設定方法
設定方法
基本設定
claude_desktop_config.jsonを編集してMCPサーバーを追加：
json
{
"mcpServers": {
"kafka": {
"command": "/Your-mcp-kafka-executable-path/mcp-kafka-darwin-arm64",
"args": [
"--bootstrap-servers=localhost:9092",
"--consumer-group-id=mcp-kafka-consumer-group",
"--username=",
"--password="
],
"env": {}
}
}
}
詳細設定
セキュリティ設定
認証情報は安全に管理し、必要に応じて環境変数を使用してください。
使用例
使用例
基本的な使用方法
プログラムでの使用
javascript
// JavaScript例（Node.js）
const { MCPClient } = require('@modelcontextprotocol/client');
const client = new MCPClient();
await client.connect();
// ツールの実行
const result = await client.callTool('toolName', {
parameter1: 'value1',
parameter2: 'value2'
});
console.log(result);
使用ケース
AIアシスタントがリアルタイムでデータを処理するためにKafkaトピックを作成する。
特定のトピックに関する詳細情報を取得し、トピックの設定を確認する。
メッセージキューを使用して、異なるシステム間でデータを非同期に送信する。
Kafkaトピックからメッセージを消費し、データ分析や処理を行う。