paws.analytics (version 0.1.7)

kafka_create_cluster: Creates a new MSK cluster

Description

        <p>Creates a new MSK cluster.</p>

Usage

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

Arguments

BrokerNodeGroupInfo

[required] <p>Information about the broker nodes in the cluster.</p>

ClientAuthentication

<p>Includes all client authentication related information.</p>

ClusterName

[required] <p>The name of the cluster.</p>

ConfigurationInfo

<p>Represents the configuration that you want MSK to use for the brokers in a cluster.</p>

EncryptionInfo

<p>Includes all encryption-related information.</p>

EnhancedMonitoring

<p>Specifies the level of monitoring for the MSK cluster. The possible values are DEFAULT, PER_BROKER, and PER_TOPIC_PER_BROKER.</p>

OpenMonitoring

<p>The settings for open monitoring.</p>

KafkaVersion

[required] <p>The version of Apache Kafka.</p>

NumberOfBrokerNodes

[required] <p>The number of broker nodes in the cluster.</p>

Tags

<p>Create tags when creating the cluster.</p>

Request syntax

svc$create_cluster(
  BrokerNodeGroupInfo = list(
    BrokerAZDistribution = "DEFAULT",
    ClientSubnets = list(
      "string"
    ),
    InstanceType = "string",
    SecurityGroups = list(
      "string"
    ),
    StorageInfo = list(
      EbsStorageInfo = list(
        VolumeSize = 123
      )
    )
  ),
  ClientAuthentication = list(
    Tls = list(
      CertificateAuthorityArnList = list(
        "string"
      )
    )
  ),
  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",
  OpenMonitoring = list(
    Prometheus = list(
      JmxExporter = list(
        EnabledInBroker = TRUE|FALSE
      ),
      NodeExporter = list(
        EnabledInBroker = TRUE|FALSE
      )
    )
  ),
  KafkaVersion = "string",
  NumberOfBrokerNodes = 123,
  Tags = list(
    "string"
  )
)