
AI SseMcpClient
CertifiedCall MCP server over SSE
AI 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') }}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.