StreamableHttpMcpClientStreamableHttpMcpClient
StreamableHttpMcpClientCertified

Model Context Protocol (MCP) SSE client tool

Model Context Protocol (MCP) SSE client tool

yaml
type: "io.kestra.plugin.ai.tool.StreamableHttpMcpClient"

Agent calling an MCP server via SSE

yaml
id: mcp_client_sse
namespace: company.ai

inputs:
  - id: prompt
    type: STRING
    defaults: Find the 2 restaurants in Lille, France with the best reviews.

tasks:
  - id: agent
    type: io.kestra.plugin.ai.agent.AIAgent
    prompt: "{{inputs.prompt}}"
    provider:
      type: io.kestra.plugin.ai.provider.GoogleGemini
      modelName: gemini-2.5-flash
      apiKey: "{{ kv('GEMINI_API_KEY') }}"
    tools:
      - type: io.kestra.plugin.ai.tool.StreamableHttpMcpClient
        url: https://mcp.apify.com/?actors=compass/crawler-google-places
        timeout: PT5M
        headers:
          Authorization: Bearer {{ kv('APIFY_API_TOKEN') }}
Properties

URL of the MCP server

SubTypestring

Custom headers

Useful, for example, for adding authentication tokens via the Authorization header.

Defaultfalse

Log requests

Defaultfalse

Log responses

Formatduration

Connection timeout duration