Apache BeamApache Beam
Apache BeamCertified

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

Execute Apache Beam pipelines defined in YAML on Direct, Flink, Spark, or Dataflow runners while forwarding Beam metrics to Kestra.

tasks

RunPipeline

Execute an Apache Beam pipeline

io.kestra.plugin.beam.RunPipeline

More Plugins in this Category

Azure
Azure

Leverage Microsoft Azure services within Kestra data workflows.

CloudMessagingStorageBatchTool

37 Tasks

2 Blueprints

Cryptography
Cryptography

Tasks that secure files in Kestra pipelines using OpenPGP encryption, decryption, and signature validation.

Transformation

2 Tasks

Google Cloud (EE)
Google Cloud
Enterprise

Integrate Google Cloud Platform services with Kestra data workflows.

StorageCloudAlertingBatch

4 Tasks

OVERVIEW
Versions
1.0.1
Latest
January 16, 2026 Release Notes Min. Compatible Kestra Version: 1.0.0
Previous Versions
1.0.0January 14, 2026 Min. Compatible Kestra Version: 1.0.0

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
TransformationBatchIngestion
Links & Resources
GitHub