naftiko: 1.0.0-alpha2
info:
  label: Strimzi Kafka Messaging
  description: Unified capability for Kafka messaging via the Strimzi Kafka Bridge REST API. Designed for application developers
    and platform engineers who need to produce and consume Kafka messages without a native Kafka client, manage consumer group
    subscriptions, and query topic metadata. Ideal for HTTP microservices, serverless functions, and legacy applications integrating
    with Kafka.
  tags:
  - Kafka
  - Kubernetes
  - Messaging
  - Operator
  - Streaming
  created: '2026-05-02'
  modified: '2026-05-06'
binds:
- namespace: env
  keys:
    KAFKA_BRIDGE_URL: KAFKA_BRIDGE_URL
capability:
  consumes:
  - type: http
    namespace: kafka-bridge
    baseUri: '{{KAFKA_BRIDGE_URL}}'
    description: Strimzi Kafka Bridge REST API
    resources:
    - name: topic-producer
      path: /topics/{topicname}
      description: Produce messages to a Kafka topic
      operations:
      - name: send
        method: POST
        description: Send messages to a Kafka topic
        inputParameters:
        - name: topicname
          in: path
          type: string
          required: true
          description: The Kafka topic name
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        body:
          type: json
          data:
            records: '{{tools.records}}'
    - name: consumer-group
      path: /consumers/{groupid}
      description: Consumer group management
      operations:
      - name: create-consumer
        method: POST
        description: Create a Kafka consumer instance
        inputParameters:
        - name: groupid
          in: path
          type: string
          required: true
          description: The consumer group ID
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        body:
          type: json
          data:
            name: '{{tools.name}}'
            format: '{{tools.format}}'
            auto.offset.reset: '{{tools.autoOffsetReset}}'
    - name: consumer-subscription
      path: /consumers/{groupid}/instances/{name}/subscription
      description: Consumer topic subscriptions
      operations:
      - name: subscribe
        method: POST
        description: Subscribe consumer to topics
        inputParameters:
        - name: groupid
          in: path
          type: string
          required: true
          description: The consumer group ID
        - name: name
          in: path
          type: string
          required: true
          description: The consumer instance name
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        body:
          type: json
          data:
            topics: '{{tools.topics}}'
      - name: list-subscriptions
        method: GET
        description: List consumer's topic subscriptions
        inputParameters:
        - name: groupid
          in: path
          type: string
          required: true
          description: The consumer group ID
        - name: name
          in: path
          type: string
          required: true
          description: The consumer instance name
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: consumer-records
      path: /consumers/{groupid}/instances/{name}/records
      description: Consumer message polling
      operations:
      - name: poll
        method: GET
        description: Poll for messages from subscribed topics
        inputParameters:
        - name: groupid
          in: path
          type: string
          required: true
          description: The consumer group ID
        - name: name
          in: path
          type: string
          required: true
          description: The consumer instance name
        - name: timeout
          in: query
          type: integer
          required: false
          description: Poll timeout in milliseconds
        - name: max_bytes
          in: query
          type: integer
          required: false
          description: Maximum response bytes
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: consumer-offsets
      path: /consumers/{groupid}/instances/{name}/offsets
      description: Offset commit
      operations:
      - name: commit
        method: POST
        description: Commit consumer offsets
        inputParameters:
        - name: groupid
          in: path
          type: string
          required: true
          description: The consumer group ID
        - name: name
          in: path
          type: string
          required: true
          description: The consumer instance name
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        body:
          type: json
          data:
            offsets: '{{tools.offsets}}'
    - name: topics
      path: /topics
      description: Topic listing
      operations:
      - name: list-topics
        method: GET
        description: List all Kafka topics
        inputParameters: []
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: topic-partitions
      path: /topics/{topicname}/partitions
      description: Topic partition metadata
      operations:
      - name: list-partitions
        method: GET
        description: Get partition metadata for a topic
        inputParameters:
        - name: topicname
          in: path
          type: string
          required: true
          description: The Kafka topic name
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
    - name: health
      path: /healthy
      description: Bridge health check
      operations:
      - name: healthy
        method: GET
        description: Check if the Bridge is healthy
        inputParameters: []
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
  exposes:
  - type: rest
    port: 8080
    namespace: strimzi-kafka-messaging-api
    description: Unified REST API for Kafka messaging via Strimzi Kafka Bridge.
    resources:
    - path: /v1/topics
      name: topics
      description: Kafka topic listing
      operations:
      - method: GET
        name: list-topics
        description: List all available Kafka topics
        call: kafka-bridge.list-topics
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/topics/{topicname}/partitions
      name: topic-partitions
      description: Topic partition metadata
      operations:
      - method: GET
        name: list-partitions
        description: Get partition metadata for a topic
        call: kafka-bridge.list-partitions
        with:
          topicname: rest.topicname
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/topics/{topicname}/messages
      name: topic-messages
      description: Message production
      operations:
      - method: POST
        name: produce-messages
        description: Produce messages to a topic
        call: kafka-bridge.send
        with:
          topicname: rest.topicname
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/consumers/{groupid}
      name: consumers
      description: Consumer group management
      operations:
      - method: POST
        name: create-consumer
        description: Create a consumer instance
        call: kafka-bridge.create-consumer
        with:
          groupid: rest.groupid
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/consumers/{groupid}/instances/{name}/subscription
      name: consumer-subscriptions
      description: Consumer subscriptions
      operations:
      - method: GET
        name: list-subscriptions
        description: List consumer subscriptions
        call: kafka-bridge.list-subscriptions
        with:
          groupid: rest.groupid
          name: rest.name
        outputParameters:
        - type: object
          mapping: $.
      - method: POST
        name: subscribe
        description: Subscribe consumer to topics
        call: kafka-bridge.subscribe
        with:
          groupid: rest.groupid
          name: rest.name
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/consumers/{groupid}/instances/{name}/records
      name: consumer-records
      description: Message consumption
      operations:
      - method: GET
        name: poll-messages
        description: Poll for messages
        call: kafka-bridge.poll
        with:
          groupid: rest.groupid
          name: rest.name
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/consumers/{groupid}/instances/{name}/offsets
      name: consumer-offsets
      description: Offset management
      operations:
      - method: POST
        name: commit-offsets
        description: Commit offsets
        call: kafka-bridge.commit
        with:
          groupid: rest.groupid
          name: rest.name
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/health
      name: health
      description: Bridge health
      operations:
      - method: GET
        name: health-check
        description: Check bridge health
        call: kafka-bridge.healthy
        outputParameters:
        - type: object
          mapping: $.
  - type: mcp
    port: 9090
    namespace: strimzi-kafka-messaging-mcp
    transport: http
    description: MCP server for AI-assisted Kafka messaging via Strimzi Kafka Bridge.
    tools:
    - name: list-topics
      description: List all available Kafka topics in the cluster
      hints:
        readOnly: true
        openWorld: true
      call: kafka-bridge.list-topics
      outputParameters:
      - type: object
        mapping: $.
    - name: get-topic-partitions
      description: Get partition metadata including leader and replica info for a topic
      hints:
        readOnly: true
      call: kafka-bridge.list-partitions
      with:
        topicname: tools.topicname
      outputParameters:
      - type: object
        mapping: $.
    - name: produce-messages
      description: Send messages to a Kafka topic (supports key, value, headers, and partition targeting)
      hints:
        readOnly: false
      call: kafka-bridge.send
      with:
        topicname: tools.topicname
      outputParameters:
      - type: object
        mapping: $.
    - name: create-consumer
      description: Create a Kafka consumer instance in a consumer group for message consumption
      hints:
        readOnly: false
      call: kafka-bridge.create-consumer
      with:
        groupid: tools.groupid
      outputParameters:
      - type: object
        mapping: $.
    - name: subscribe-to-topics
      description: Subscribe a consumer to one or more Kafka topics
      hints:
        readOnly: false
      call: kafka-bridge.subscribe
      with:
        groupid: tools.groupid
        name: tools.name
      outputParameters:
      - type: object
        mapping: $.
    - name: list-subscriptions
      description: List the topics a consumer is subscribed to
      hints:
        readOnly: true
      call: kafka-bridge.list-subscriptions
      with:
        groupid: tools.groupid
        name: tools.name
      outputParameters:
      - type: object
        mapping: $.
    - name: poll-messages
      description: Poll for messages from subscribed Kafka topics (long-poll with configurable timeout)
      hints:
        readOnly: true
        openWorld: true
      call: kafka-bridge.poll
      with:
        groupid: tools.groupid
        name: tools.name
        timeout: tools.timeout
        max_bytes: tools.max_bytes
      outputParameters:
      - type: object
        mapping: $.
    - name: commit-offsets
      description: Commit consumer offsets to checkpoint consumption progress
      hints:
        readOnly: false
        idempotent: true
      call: kafka-bridge.commit
      with:
        groupid: tools.groupid
        name: tools.name
      outputParameters:
      - type: object
        mapping: $.