mcp-kafka-processor
The MCP Kafka Processor is a server implementation that leverages Kafka for event processing, enabling integration with Large Language Models via the Model Context Protocol. It facilitates message publishing and consumption across Kafka topics with TypeScript support for a type-safe experience.
IyBNQ1AgS2Fma2EgUHJvY2Vzc29yCgpBbiBNQ1Agc2VydmVyIGltcGxlbWVudGF0aW9uIHRoYXQgcHJvdmlkZXMgZXZlbnQgcHJvY2Vzc2luZyBjYXBhYmlsaXRpZXMgdGhyb3VnaCBLYWZrYSBpbnRlZ3JhdGlvbi4gVGhpcyBzZXJ2ZXIgYWxsb3dzIExhcmdlIExhbmd1YWdlIE1vZGVscyB0byBpbnRlcmFjdCB3aXRoIEthZmthIHRvcGljcyB0aHJvdWdoIHRoZSBNb2RlbCBDb250ZXh0IFByb3RvY29sLgoKIyMgRmVhdHVyZXMKCi0gUHVibGlzaCBldmVudHMgdG8gS2Fma2EgdG9waWNzCi0gQ29uc3VtZSBldmVudHMgZnJvbSBLYWZrYSB0b3BpY3MKLSBFYXN5IGludGVncmF0aW9uIHdpdGggQ2xhdWRlIERlc2t0b3AgYW5kIG90aGVyIE1DUCBjbGllbnRzCi0gVHlwZS1zYWZlIGltcGxlbWVudGF0aW9uIHVzaW5nIFR5cGVTY3JpcHQKCiMjIFByZXJlcXVpc2l0ZXMKCi0gTm9kZS5qcyAxNiBvciBoaWdoZXIKLSBLYWZrYSBicm9rZXIgYWNjZXNzaWJsZQotIFR5cGVTY3JpcHQga25vd2xlZGdlIGZvciBkZXZlbG9wbWVudAoKIyMgSW5zdGFsbGF0aW9uCgpgYGBiYXNoCiMgQ2xvbmUgdGhlIHJlcG9zaXRvcnkKZ2l0IGNsb25lIGh0dHBzOi8vZ2l0aHViLmNvbS9ib3VmbmljaGVsL21jcC1rYWZrYS1wcm9jZXNzb3IuZ2l0CmNkIG1jcC1rYWZrYS1wcm9jZXNzb3IKCiMgSW5zdGFsbCBkZXBlbmRlbmNpZXMKbnBtIGluc3RhbGwKCiMgQnVpbGQgdGhlIHByb2plY3QKbnBtIHJ1biBidWlsZApgYGAKCiMjIENvbmZpZ3VyYXRpb24KClRoZSBzZXJ2ZXIgY2FuIGJlIGNvbmZpZ3VyZWQgdXNpbmcgZW52aXJvbm1lbnQgdmFyaWFibGVzOgoKLSBgS0FGS0FfQlJPS0VSU2A6IENvbW1hLXNlcGFyYXRlZCBsaXN0IG9mIEthZmthIGJyb2tlcnMgKGRlZmF1bHQ6ICJsb2NhbGhvc3Q6OTA5MiIpCgojIyBVc2FnZSB3aXRoIENsYXVkZSBEZXNrdG9wCgpBZGQgdGhlIGZvbGxvd2luZyB0byB5b3VyIENsYXVkZSBEZXNrdG9wIGNvbmZpZ3VyYXRpb24gKGBjbGF1ZGVfZGVza3RvcF9jb25maWcuanNvbmApOgoKYGBganNvbgp7CiAgIm1jcFNlcnZlcnMiOiB7CiAgICAiZXZlbnQtcHJvY2Vzc29yIjogewogICAgICAiY29tbWFuZCI6ICJub2RlIiwKICAgICAgImFyZ3MiOiBbIi9hYnNvbHV0ZS9wYXRoL3RvL2J1aWxkL2luZGV4LmpzIl0sCiAgICAgICJlbnYiOiB7CiAgICAgICAgIktBRktBX0JST0tFUlMiOiAibG9jYWxob3N0OjkwOTIiCiAgICAgIH0KICAgIH0KICB9Cn0KYGBgCgojIyBBdmFpbGFibGUgVG9vbHMKCiMjIyBwdWJsaXNoLWV2ZW50CgpQdWJsaXNoZXMgYSBtZXNzYWdlIHRvIGEgc3BlY2lmaWVkIEthZmthIHRvcGljLgoKUGFyYW1ldGVyczoKLSBgdG9waWNgOiBUaGUgS2Fma2EgdG9waWMgdG8gcHVibGlzaCB0bwotIGBtZXNzYWdlYDogVGhlIG1lc3NhZ2UgY29udGVudCB0byBwdWJsaXNoCi0gYGtleWA6IE9wdGlvbmFsIG1lc3NhZ2Uga2V5CgojIyMgY29uc3VtZS1ldmVudHMKCkNvbnN1bWVzIG1lc3NhZ2VzIGZyb20gYSBzcGVjaWZpZWQgS2Fma2EgdG9waWMuCgpQYXJhbWV0ZXJzOgotIGB0b3BpY2A6IFRoZSBLYWZrYSB0b3BpYyB0byBjb25zdW1lIGZyb20KLSBgbWF4TWVzc2FnZXNgOiBNYXhpbXVtIG51bWJlciBvZiBtZXNzYWdlcyB0byBjb25zdW1lIChkZWZhdWx0OiAxMCkKCiMjIERldmVsb3BtZW50CgpgYGBiYXNoCiMgSW5zdGFsbCBkZXBlbmRlbmNpZXMKbnBtIGluc3RhbGwKCiMgQnVpbGQgdGhlIHByb2plY3QKbnBtIHJ1biBidWlsZAoKIyBTdGFydCB0aGUgc2VydmVyCm5wbSBzdGFydApgYGAKCiMjIExpY2Vuc2UKCk1JVA==