Connect anything to everything

Tasks that provide Kestra's built-in orchestration, I/O, and observability capabilities.

Tasks that connect to Actian Vector (VectorWise) via JDBC to run queries and loads.

Tasks that work with Azure Data Lake Storage for large-scale file operations and analytics workloads.

Tasks that run AI agents combining system prompts, user input, tools, content retrievers, and optional memory to produce grounded responses.

Tasks that manage AHV VM lifecycle in Nutanix.

Tasks that orchestrate generative AI in Kestra with LangChain4j, covering chat completions, agents, RAG, tools, and shared providers.

Seamlessly integrate Airbyte connectors into your Kestra workflows.

Tasks that read and write Airtable records: list rows with filters, views, and pagination, fetch a record by ID, create single or batched records with optional typecasting, patch updates, and deletes.

Tasks that integrate with Algolia Search to index, query, and delete records.

Tasks that send Kestra logs to Amazon CloudWatch Logs for centralized monitoring.

Tasks that export Kestra logs to Amazon S3 for durable storage and downstream analysis.

Tasks that connect to RabbitMQ brokers to declare exchanges and queues, bind routing keys, publish messages, and consume them via tasks or triggers (batch or real time).

Tasks that orchestrate Ansible playbooks from Kestra flows.

Tasks that call Anthropic Claude models for chat completions.

Tasks that run pipelines against SDKs and dedicated runners including Apache Flink

Tasks that integrate Apache Cassandra into Kestra workflows for querying and event-driven triggers.

Tasks that connect to Apache Druid via JDBC to run queries and loads.

Tasks that submit, monitor, cancel, and trigger savepoints for Apache Flink jobs over the REST API.

Tasks that produce, consume, and trigger workflows from Apache Kafka topics.

Tasks that connect to Apache Pinot via JDBC to run queries and loads.

Tasks that publish, consume, and trigger workflows with Apache Pulsar.

Tasks that submit Apache Spark jobs and run Spark CLI commands.

Tasks that extract text and metadata from files using Apache Tika.

Tasks that orchestrate Apify Actors and datasets from Kestra.

Tasks that run Apify Actors with configurable inputs, limits, and webhooks.

Tasks that retrieve Apify dataset items or export them to storage with filtering.

Tasks that define Kestra Enterprise Apps for interacting with flows and executions through custom layouts.

Tasks that connect to Apache Arrow Flight SQL via JDBC to run queries and loads.

Tasks that connect to AS400 via JDBC to run queries and loads.

Tasks that run CQL queries and triggers on DataStax Astra DB.

Tasks that run Amazon Athena SQL queries against data in S3 or federated sources, writing results to an S3 output location and optionally fetching rows.

Tasks that create alerts in Opsgenie.

Tasks that generate authentication material for AWS services, such as short-lived tokens to access Amazon EKS clusters.

Tasks that obtain Azure access tokens for authenticated calls to other services.

This sub-group of plugins contains tasks to manage authentication for Google Cloud.

Tasks that convert to/from Apache Avro and validate schemas.

AWS plugin for Kestra

AWS plugin for Kestra

Tasks that run Kestra workloads through AWS Batch on ECS-managed containers.