Hi everyone,

I would like to start a discussion on *KIP-1318: Model Context Protocol
(MCP) Server for Apache Kafka*.

*KIP Interface:* KIP-1318 Wiki
<https://cwiki.apache.org/confluence/display/KAFKA/KIP-1318%3A+Model+Context+Protocol+%28MCP%29+Server+for+Apache+Kafka>
 *JIRA:* KAFKA-20436 <https://issues.apache.org/jira/browse/KAFKA-20436>

*Motivation*:

Currently, interacting with Apache Kafka programmatically requires writing
Java/Python code, using CLI tools, or relying on Connect REST APIs none of
which are natively accessible to autonomous AI agents via the Model Context
Protocol (MCP).

While some community-led MCP implementations for Kafka exist, they often
lack critical enterprise capabilities like ACL management and transactional
operations, or they are tightly coupled to specific vendor platforms. This
KIP proposes adding a first-party, Apache-licensed MCP server to the Kafka
project.
Key Highlights

   -

   *New Standalone Module:* Introduces tools/mcp-server, a JSON-RPC 2.0
   server that runs outside the broker process.
   -

   *Zero Protocol Changes:* This proposal requires no changes to the Kafka
   wire protocol or existing public APIs. It acts as a wrapper around native
   Java client APIs.
   -

   *AI-Native Operations:* Allows AI agents to manage topics, handle
   consumer groups, and read/write messages using a standardized interface.
   -

   *Security First:* It will pass through all standard Kafka security
   properties (SASL, SSL, ACLs) directly to the underlying clients.

I look forward to your feedback and suggestions.


Regards,
Vaquar Khan
*Linkedin *-https://www.linkedin.com/in/vaquar-khan-b695577/

Reply via email to