Star
Contact SalesGet Started
    • Core Features
    • Enterprise Edition
    • Cloud EditionRequest Access
    • Platform Overview
    • Use-cases

    • Data Workflow
    • Infrastructure Automation
    • AI Workflows

      Users

    • Data Engineers
    • Software Engineers
    • Platform Engineers

      Industries

    • Finance
    • Automotive
    • Retail
    • Healthcare
    • Public Services
    • Software & Services
  • Plugins
    • Docs
    • Integrations
    • Blueprints
    • Blog
    • Customer Stories
    • Courses
    • About Us
    • CareersHiring!
    • Partners
    • Contact us
  • Pricing
  • Get Started Join us on SlackBook a Demo
  • Core Features
  • Enterprise Edition
  • Cloud EditionRequest Access
  • Platform Overview

Use-cases

  • Data Workflow
  • Infrastructure Automation
  • AI Workflows

Users

  • Data Engineers
  • Software Engineers
  • Platform Engineers

Industries

  • Finance
  • Automotive
  • Retail
  • Healthcare
  • Public Services
  • Software & Services
  • Docs
  • Integrations
  • Blueprints
  • Blog
  • Customer Stories
  • Courses
  • About Us
  • CareersHiring!
  • Partners
  • Contact us
ESC
Ask Kestra AI
ESC
Kestra AI

Hi! I'm your Kestra AI assistant.
Ask me anything about workflows.

EXAMPLE QUESTIONS

How to handle errors & retry on flow?
How to configure my internal storage?
How to prevent concurrent execution of the same flow?

AWS

AWS HealthLake
  • CreateDatastore
  • DeleteDatastore
  • DescribeDatastore
  • DescribeExportJob
  • DescribeImportJob
  • ListDatastores
  • StartExportJob
  • StartImportJob
  • Trigger
AWS S3
  • Copy
  • CreateBucket
  • Delete
  • DeleteList
  • Download
  • Downloads
  • List
  • Upload
  • Trigger
AWS EFS
  • CreateFileSystem
  • CreateMountTarget
  • DeleteFileSystem
  • DeleteMountTarget
  • GetFileSystem
  • ListFileSystems
  • ListMountTargets
AWS SNS
  • Publish
AWS CloudFormation
  • Create
  • Delete
AWS Authentication
  • EksToken
AWS Eventbridge
  • PutEvents
AWS SQS
  • Consume
  • Publish
  • RealtimeTrigger
  • Trigger
AWS ECR
  • GetAuthToken
AWS Bedrock
  • Converse
  • ConverseStream
  • InvokeModel
  • ListFoundationModels
AWS Glue
  • GetJobRun
  • StartJobRun
  • StopJobRun
AWS EMR
  • CreateClusterAndSubmitSteps
  • CreateServerlessApplicationAndStartJob
  • DeleteCluster
  • DeleteServerlessApplication
  • StartServerlessJobRun
  • SubmitSteps
AWS Kinesis
  • Consume
  • PutRecords
  • RealtimeTrigger
  • Trigger
AWS Athena
  • Query
AWS DynamoDB
  • DeleteItem
  • GetItem
  • PutItem
  • Query
  • Scan
AWS Lambda
  • Invoke
AWS CLI
  • AwsCLI
AWS MSK
  • CreateCluster
  • DeleteCluster
  • DescribeCluster
  • GetBootstrapBrokers
  • ListClusters
  • Trigger
AWS CloudWatch
  • Push
  • Query
  • Trigger

Request a plugin

Ask on Slack

Create a plugin

Go to the developer platform
OVERVIEW

Plugins have a Min. Compatible Kestra Version i.e. a Kestra version from where the corresponding plugin version is compatible. Learn More

Versions
July 7, 2026 Release Notes Min.compatible Kestra ver.: 1.3.19

Created by

author iconKestra Core Team

Managed by

author iconKestra Core Team

Plugin Type

Cloud

Links & Resources

GitHub
Table of Contents
  • Tasks
  • Triggers
  • More Plugins in this Category
Get Involved
  • GitHub
  • Join Us on Slack
  • YouTube
  • LinkedIn
  • Twitter
  • Bluesky
Share this Plugin
  1. Plugins
  2. AWS
  3. AWS MSK

AWS MSK

AWS MSK

Certified

Tasks to manage Amazon MSK (Managed Streaming for Apache Kafka) cluster lifecycle and retrieve bootstrap broker connection strings for use with plugin-kafka.

tasks

CreateCluster

Create an Amazon MSK cluster

io.kestra.plugin.aws.msk.CreateCluster
DeleteCluster

Delete an Amazon MSK cluster

io.kestra.plugin.aws.msk.DeleteCluster
DescribeCluster

Describe an Amazon MSK cluster

io.kestra.plugin.aws.msk.DescribeCluster
GetBootstrapBrokers

Get bootstrap broker strings for an Amazon MSK cluster

io.kestra.plugin.aws.msk.GetBootstrapBrokers
ListClusters

List Amazon MSK clusters

io.kestra.plugin.aws.msk.ListClusters

triggers

Trigger

Trigger a flow when an MSK cluster reaches a target state

io.kestra.plugin.aws.msk.Trigger

More Plugins in this Category

Proxmox VE
Proxmox VE

Tasks that manage the full lifecycle of QEMU VMs and LXC containers on Proxmox VE, including backups, snapshots, cluster introspection, and network inspection.

CloudInfrastructure

36 tasks

4 blueprints

HPE Morpheus
HPE Morpheus
Enterprise

Plugin for interacting with HPE Morpheus (HPE VM Essentials) cloud management platform

CloudInfrastructure

5 tasks

Get Kestra Updates

SOC 2GDPR
Kestra's logo

Open Source Declarative
Orchestration Platform

Get Started
  • Getting Started
  • Documentation
  • Blueprints
  • Plugins
  • FAQs
Learn
  • Blogs
  • Resources
  • Videos
  • Kestra Academy
  • Administrator Guide
  • Release Notes
  • API Reference
Resources
  • All Comparisons
  • All Integrations
  • Resources Center
Industries
  • Finance
  • Healthcare
  • Public Services
  • Software & Services
  • Retail
  • Automotive
Community
  • Community Overview
  • Slack
  • GitHub
  • Write for Us
Company
  • About Us
  • Partners
  • Careers Hiring!
  • Contact

© 2026 Kestra Technologies. Developed with ♥ on 🌎.

Privacy PolicyCookie Policy