AI StreamableHttpMcpClient

AI 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 and default to provider values with logging off.

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

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: "{{ 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') }}
Properties

URL of the MCP server

Custom headers

Useful, for example, for adding authentication tokens via the Authorization header.

Defaultfalse

Log requests

Defaultfalse

Log responses

Connection timeout duration

More Plugins in this Category

Weaviate
Weaviate

Tasks that manage and query vectors in Weaviate.

DataAI

4 tasks

2 blueprints

Mistral
Mistral

Tasks and triggers for Mistral AI: chat completions and workflow orchestration.

AI

3 tasks