
SseMcpClient
SseMcpClient
Model Context Protocol (MCP) SSE client tool
yaml
type: "io.kestra.plugin.ai.tool.SseMcpClient"Examples
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
sseUrl*Requiredstring
SSE URL of the MCP server
headersobject
SubTypestring
Custom headers
Could be useful, for example, to add authentication tokens via the Authorization header.
logRequestsbooleanstring
Default
falseLog requests
logResponsesbooleanstring
Default
falseLog responses
timeoutstring
Format
durationConnection timeout duration