
Tool SseMcpClient
CertifiedCall MCP server over SSE
Tool SseMcpClient
Call MCP server over SSE
Connects to an MCP server that streams Server-Sent Events and exposes its tools to the agent. Requires sseUrl; timeout is optional. Request/response logging is disabled by default; add headers for auth tokens.
type: io.kestra.plugin.ai.tool.SseMcpClientExamples
Agent calling an MCP server via SSE
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-3.5-flash-lite
apiKey: "{{ secret('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 {{ secret('APIFY_API_TOKEN') }}Installation
Our standard Docker images already include this plugin. If you use a -slim image or another setup, install it with the following command:
kestractl plugins get io.kestra.plugin:plugin-ai --compatible-for $KESTRA_VERSION For kestractl, use your Kestra version with --compatible-for, or specify an exact plugin version.
For Kestra CLI, replace LATEST with a specific version or version range to pin the plugin version.
Properties
sseUrl *string
SSE URL of the MCP server
Server-Sent Events endpoint of the MCP server exposing the tools. No default: this property is required.
headers object
Custom headers
Extra HTTP headers sent with every request, typically to carry an authentication token via the Authorization header. Not set by default.
logRequests booleanstring
falseLog requests
If true, requests sent to the MCP server are logged at INFO level. Defaults to false.
logResponses booleanstring
falseLog responses
If true, responses received from the MCP server are logged at INFO level. Defaults to false.
timeout string
Connection timeout duration
Maximum time to wait for a response from the MCP server. Not set by default, in which case the MCP transport's own default applies.