mcp-kafka Binding

The client kind mcp-kafka binding exposes a fixed set of Kafka broker operations — producing and consuming records, managing topics and their configs, and inspecting brokers and consumer groups — as intrinsic MCP tools, connecting directly to the Kafka cluster named by options.servers, with no upstream MCP or REST server and no per-tool schema authoring.

client

Full config

Behave as an mcp-kafka client.

mcp_kafka_client:
  type: mcp-kafka
  kind: client
  options:
    servers:
      - kafka.examples.dev:9092
  routes:
    - when:
        - tool: create_topics
        - tool: delete_topics
        - tool: alter_topic_configs
        - tool: alter_broker_configs
        - tool: reset_offsets
      guarded:
        my_guard:
          - kafka:admin
    - when:
        - tool: produce_message
          topics: [ orders ]
      guarded:
        my_guard:
          - kafka:write
    - when:
        - tool: consume_messages
          topics: [ orders ]
    - when:
        - tool: describe_topic_configs
        - tool: describe_broker_configs
        - tool: list_topics
        - tool: describe_topic
        - tool: cluster_overview
        - tool: list_brokers
        - tool: describe_cluster
        - tool: list_consumer_groups
        - tool: describe_consumer_group