Tool StreamableHttpMcpClient

Tool StreamableHttpMcpClient
Certified
Call MCP server over HTTP streaming

Connects to an MCP server via HTTP streaming (chunked responses) and surfaces its tools to the agent. Requires url; timeout, headers, logRequests, and logResponses are optional, with request/response logging off by default.

yaml
type: io.kestra.plugin.ai.tool.StreamableHttpMcpClient

Examples

Agent calling an MCP server via HTTP streaming

yaml
id: mcp_client_streamable_http
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-3.5-flash-lite
      apiKey: "{{ secret('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 {{ 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

url *string

URL of the MCP server

Streamable HTTP 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

Defaultfalse

Log requests

If true, requests sent to the MCP server are logged at INFO level. Defaults to false.

logResponses booleanstring

Defaultfalse

Log 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.

Timefold

Timefold plugin for Kestra

DataAI

Browser Use

Run a Browser Use cloud agent and wait for its result.

Tool StreamableHttpMcpClientCertifiedCall MCP server over HTTP streaming

Tool StreamableHttpMcpClient

More Plugins in this Category

Timefold

Browser Use

Tool StreamableHttpMcpClient
Certified
Call MCP server over HTTP streaming