SseMcpClientSseMcpClient
​Sse​Mcp​ClientCertified

Model Context Protocol (MCP) SSE client tool

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

Agent calling an MCP server via SSE

yaml
id: mcp_client_sse
namespace: company.ai

inputs:
  - id: prompt
    type: STRING
    defaults: Find 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.SseMcpClient
        sseUrl: https://mcp.apify.com/?actors=compass/crawler-google-places
        timeout: PT5M
        headers:
          Authorization: Bearer {{ kv('APIFY_API_TOKEN') }}
Properties

SSE URL of the MCP server

SubTypestring

Custom headers

Could be useful, for example, to add authentication tokens via the Authorization header.

Defaultfalse

Log requests

Defaultfalse

Log responses

Formatduration

Connection timeout duration