CreateCluster

CreateCluster
Certified
Create an Amazon MSK cluster

yaml
type: io.kestra.plugin.aws.msk.CreateCluster

Examples

yaml
id: provision_msk_cluster
namespace: company.team

tasks:
  - id: create_cluster
    type: io.kestra.plugin.aws.msk.CreateCluster
    region: "{{ secret('AWS_REGION') }}"
    accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
    secretKeyId: "{{ secret('AWS_SECRET_ACCESS_KEY') }}"
    clusterName: "my-kestra-msk"
    kafkaVersion: "3.5.1"
    numberOfBrokerNodes: 3
    instanceType: "kafka.m5.large"
    clientSubnets:
      - "{{ secret('SUBNET_A') }}"
      - "{{ secret('SUBNET_B') }}"
      - "{{ secret('SUBNET_C') }}"
    securityGroups:
      - "{{ secret('SECURITY_GROUP_ID') }}"

  - id: log_arn
    type: io.kestra.plugin.core.log.Log
    message: "MSK cluster ARN: {{ outputs.create_cluster.clusterArn }}"

Properties

clientSubnets *array

SubTypestring

clusterName *string

instanceType *string

kafkaVersion *string

numberOfBrokerNodes *integerstring

securityGroups *array

SubTypestring

accessKeyId string

compatibilityMode booleanstring

ebsVolumeSize integerstring

endpointOverride string

forcePathStyle booleanstring

pluginDefaultsRef string

region string

secretKeyId string

sessionToken string

stsEndpointOverride string

stsRoleArn string

stsRoleExternalId string

stsRoleSessionDuration string

DefaultPT15M

stsRoleSessionName string

Outputs

clusterArn string

clusterName string

state string

NetBox

Enterprise

Enterprise NetBox tasks to create, update, and query devices, IP addresses, and sites over the NetBox API.

Infrastructure

DocumentDB

Tasks that manage DocumentDB collections with MongoDB-compatible insert, query, update, and delete operations.

Data

CreateClusterCertifiedCreate an Amazon MSK cluster

More Plugins in this Category

NetBox

DocumentDB

CreateCluster
Certified
Create an Amazon MSK cluster