Create Cluster

kafka_create_cluster

R Documentation

Creates a new MSK cluster

Description

Creates a new MSK cluster.

Usage

kafka_create_cluster(BrokerNodeGroupInfo, ClientAuthentication,
  ClusterName, ConfigurationInfo, EncryptionInfo, EnhancedMonitoring,
  OpenMonitoring, KafkaVersion, LoggingInfo, NumberOfBrokerNodes, Tags,
  StorageMode)

Arguments

BrokerNodeGroupInfo

[required] Information about the broker nodes in the cluster.

ClientAuthentication

Includes all client authentication related information.

ClusterName

[required] The name of the cluster.

ConfigurationInfo

Represents the configuration that you want MSK to use for the brokers in a cluster.

EncryptionInfo

Includes all encryption-related information.

EnhancedMonitoring

Specifies the level of monitoring for the MSK cluster. The possible values are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.

OpenMonitoring

The settings for open monitoring.

KafkaVersion

[required] The version of Apache Kafka.

LoggingInfo

NumberOfBrokerNodes

[required] The number of broker nodes in the cluster.

Tags

Create tags when creating the cluster.

StorageMode

This controls storage mode for supported storage tiers.

Value

A list with the following syntax:

list(
  ClusterArn = "string",
  ClusterName = "string",
  State = "ACTIVE"|"CREATING"|"DELETING"|"FAILED"|"HEALING"|"MAINTENANCE"|"REBOOTING_BROKER"|"UPDATING"
)

Request syntax

svc$create_cluster(
  BrokerNodeGroupInfo = list(
    BrokerAZDistribution = "DEFAULT",
    ClientSubnets = list(
      "string"
    ),
    InstanceType = "string",
    SecurityGroups = list(
      "string"
    ),
    StorageInfo = list(
      EbsStorageInfo = list(
        ProvisionedThroughput = list(
          Enabled = TRUE|FALSE,
          VolumeThroughput = 123
        ),
        VolumeSize = 123
      )
    ),
    ConnectivityInfo = list(
      PublicAccess = list(
        Type = "string"
      ),
      VpcConnectivity = list(
        ClientAuthentication = list(
          Sasl = list(
            Scram = list(
              Enabled = TRUE|FALSE
            ),
            Iam = list(
              Enabled = TRUE|FALSE
            )
          ),
          Tls = list(
            Enabled = TRUE|FALSE
          )
        )
      )
    ),
    ZoneIds = list(
      "string"
    )
  ),
  ClientAuthentication = list(
    Sasl = list(
      Scram = list(
        Enabled = TRUE|FALSE
      ),
      Iam = list(
        Enabled = TRUE|FALSE
      )
    ),
    Tls = list(
      CertificateAuthorityArnList = list(
        "string"
      ),
      Enabled = TRUE|FALSE
    ),
    Unauthenticated = list(
      Enabled = TRUE|FALSE
    )
  ),
  ClusterName = "string",
  ConfigurationInfo = list(
    Arn = "string",
    Revision = 123
  ),
  EncryptionInfo = list(
    EncryptionAtRest = list(
      DataVolumeKMSKeyId = "string"
    ),
    EncryptionInTransit = list(
      ClientBroker = "TLS"|"TLS_PLAINTEXT"|"PLAINTEXT",
      InCluster = TRUE|FALSE
    )
  ),
  EnhancedMonitoring = "DEFAULT"|"PER_BROKER"|"PER_TOPIC_PER_BROKER"|"PER_TOPIC_PER_PARTITION",
  OpenMonitoring = list(
    Prometheus = list(
      JmxExporter = list(
        EnabledInBroker = TRUE|FALSE
      ),
      NodeExporter = list(
        EnabledInBroker = TRUE|FALSE
      )
    )
  ),
  KafkaVersion = "string",
  LoggingInfo = list(
    BrokerLogs = list(
      CloudWatchLogs = list(
        Enabled = TRUE|FALSE,
        LogGroup = "string"
      ),
      Firehose = list(
        DeliveryStream = "string",
        Enabled = TRUE|FALSE
      ),
      S3 = list(
        Bucket = "string",
        Enabled = TRUE|FALSE,
        Prefix = "string"
      )
    )
  ),
  NumberOfBrokerNodes = 123,
  Tags = list(
    "string"
  ),
  StorageMode = "LOCAL"|"TIERED"
)