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