Mcp Kafka Processor

by boufnichel

325 downloads
Not rated
GitHub

About

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

Details

Author
boufnichel
Downloads
325
Categories
Productivity

- 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

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.

IyBNQ1AgS2Fma2EgUHJvY2Vzc29yCgpBbiBNQ1Agc2VydmVyIGltcGxlbWVudGF0aW9uIHRoYXQgcHJvdmlkZXMgZXZlbnQgcHJvY2Vzc2luZyBjYXBhYmlsaXRpZXMgdGhyb3VnaCBLYWZrYSBpbnRlZ3JhdGlvbi4gVGhpcyBzZXJ2ZXIgYWxsb3dzIExhcmdlIExhbmd1YWdlIE1vZGVscyB0byBpbnRlcmFjdCB3aXRoIEthZmthIHRvcGljcyB0aHJvdWdoIHRoZSBNb2RlbCBDb250ZXh0IFByb3RvY29sLgoKIyMgRmVhdHVyZXMKCi0gUHVibGlzaCBldmVudHMgdG8gS2Fma2EgdG9waWNzCi0gQ29uc3VtZSBldmVudHMgZnJvbSBLYWZrYSB0b3BpY3MKLSBFYXN5IGludGVncmF0aW9uIHdpdGggQ2xhdWRlIERlc2t0b3AgYW5kIG90aGVyIE1DUCBjbGllbnRzCi0gVHlwZS1zYWZlIGltcGxlbWVudGF0aW9uIHVzaW5nIFR5cGVTY3JpcHQKCiMjIFByZXJlcXVpc2l0ZXMKCi0gTm9kZS5qcyAxNiBvciBoaWdoZXIKLSBLYWZrYSBicm9rZXIgYWNjZXNzaWJsZQotIFR5cGVTY3JpcHQga25vd2xlZGdlIGZvciBkZXZlbG9wbWVudAoKIyMgSW5zdGFsbGF0aW9uCgpgYGBiYXNoCiMgQ2xvbmUgdGhlIHJlcG9zaXRvcnkKZ2l0IGNsb25lIGh0dHBzOi8vZ2l0aHViLmNvbS9ib3VmbmljaGVsL21jcC1rYWZrYS1wcm9jZXNzb3IuZ2l0CmNkIG1jcC1rYWZrYS1wcm9jZXNzb3IKCiMgSW5zdGFsbCBkZXBlbmRlbmNpZXMKbnBtIGluc3RhbGwKCiMgQnVpbGQgdGhlIHByb2plY3QKbnBtIHJ1biBidWlsZApgYGAKCiMjIENvbmZpZ3VyYXRpb24KClRoZSBzZXJ2ZXIgY2FuIGJlIGNvbmZpZ3VyZWQgdXNpbmcgZW52aXJvbm1lbnQgdmFyaWFibGVzOgoKLSBgS0FGS0FfQlJPS0VSU2A6IENvbW1hLXNlcGFyYXRlZCBsaXN0IG9mIEthZmthIGJyb2tlcnMgKGRlZmF1bHQ6ICJsb2NhbGhvc3Q6OTA5MiIpCgojIyBVc2FnZSB3aXRoIENsYXVkZSBEZXNrdG9wCgpBZGQgdGhlIGZvbGxvd2luZyB0byB5b3VyIENsYXVkZSBEZXNrdG9wIGNvbmZpZ3VyYXRpb24gKGBjbGF1ZGVfZGVza3RvcF9jb25maWcuanNvbmApOgoKYGBganNvbgp7CiAgIm1jcFNlcnZlcnMiOiB7CiAgICAiZXZlbnQtcHJvY2Vzc29yIjogewogICAgICAiY29tbWFuZCI6ICJub2RlIiwKICAgICAgImFyZ3MiOiBbIi9hYnNvbHV0ZS9wYXRoL3RvL2J1aWxkL2luZGV4LmpzIl0sCiAgICAgICJlbnYiOiB7CiAgICAgICAgIktBRktBX0JST0tFUlMiOiAibG9jYWxob3N0OjkwOTIiCiAgICAgIH0KICAgIH0KICB9Cn0KYGBgCgojIyBBdmFpbGFibGUgVG9vbHMKCiMjIyBwdWJsaXNoLWV2ZW50CgpQdWJsaXNoZXMgYSBtZXNzYWdlIHRvIGEgc3BlY2lmaWVkIEthZmthIHRvcGljLgoKUGFyYW1ldGVyczoKLSBgdG9waWNgOiBUaGUgS2Fma2EgdG9waWMgdG8gcHVibGlzaCB0bwotIGBtZXNzYWdlYDogVGhlIG1lc3NhZ2UgY29udGVudCB0byBwdWJsaXNoCi0gYGtleWA6IE9wdGlvbmFsIG1lc3NhZ2Uga2V5CgojIyMgY29uc3VtZS1ldmVudHMKCkNvbnN1bWVzIG1lc3NhZ2VzIGZyb20gYSBzcGVjaWZpZWQgS2Fma2EgdG9waWMuCgpQYXJhbWV0ZXJzOgotIGB0b3BpY2A6IFRoZSBLYWZrYSB0b3BpYyB0byBjb25zdW1lIGZyb20KLSBgbWF4TWVzc2FnZXNgOiBNYXhpbXVtIG51bWJlciBvZiBtZXNzYWdlcyB0byBjb25zdW1lIChkZWZhdWx0OiAxMCkKCiMjIERldmVsb3BtZW50CgpgYGBiYXNoCiMgSW5zdGFsbCBkZXBlbmRlbmNpZXMKbnBtIGluc3RhbGwKCiMgQnVpbGQgdGhlIHByb2plY3QKbnBtIHJ1biBidWlsZAoKIyBTdGFydCB0aGUgc2VydmVyCm5wbSBzdGFydApgYGAKCiMjIExpY2Vuc2UKCk1JVA==

No reviews yet — be the first

Sign in to leave a review

Use Google, GitHub, or an email account so ratings stay tied to real people.

Email sign in

No reviews posted yet.