Class CfnClusterProps
Properties for defining a CfnCluster
.
Inheritance
Implements
Namespace: Amazon.CDK.AWS.MSK
Assembly: Amazon.CDK.Lib.dll
Syntax (csharp)
public class CfnClusterProps : Object, ICfnClusterProps
Syntax (vb)
Public Class CfnClusterProps
Inherits Object
Implements ICfnClusterProps
Remarks
See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-msk-cluster.html
ExampleMetadata: fixture=_generated
Examples
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
using Amazon.CDK.AWS.MSK;
var cfnClusterProps = new CfnClusterProps {
BrokerNodeGroupInfo = new BrokerNodeGroupInfoProperty {
ClientSubnets = new [] { "clientSubnets" },
InstanceType = "instanceType",
// the properties below are optional
BrokerAzDistribution = "brokerAzDistribution",
ConnectivityInfo = new ConnectivityInfoProperty {
PublicAccess = new PublicAccessProperty {
Type = "type"
},
VpcConnectivity = new VpcConnectivityProperty {
ClientAuthentication = new VpcConnectivityClientAuthenticationProperty {
Sasl = new VpcConnectivitySaslProperty {
Iam = new VpcConnectivityIamProperty {
Enabled = false
},
Scram = new VpcConnectivityScramProperty {
Enabled = false
}
},
Tls = new VpcConnectivityTlsProperty {
Enabled = false
}
}
}
},
SecurityGroups = new [] { "securityGroups" },
StorageInfo = new StorageInfoProperty {
EbsStorageInfo = new EBSStorageInfoProperty {
ProvisionedThroughput = new ProvisionedThroughputProperty {
Enabled = false,
VolumeThroughput = 123
},
VolumeSize = 123
}
}
},
ClusterName = "clusterName",
KafkaVersion = "kafkaVersion",
NumberOfBrokerNodes = 123,
// the properties below are optional
ClientAuthentication = new ClientAuthenticationProperty {
Sasl = new SaslProperty {
Iam = new IamProperty {
Enabled = false
},
Scram = new ScramProperty {
Enabled = false
}
},
Tls = new TlsProperty {
CertificateAuthorityArnList = new [] { "certificateAuthorityArnList" },
Enabled = false
},
Unauthenticated = new UnauthenticatedProperty {
Enabled = false
}
},
ConfigurationInfo = new ConfigurationInfoProperty {
Arn = "arn",
Revision = 123
},
CurrentVersion = "currentVersion",
EncryptionInfo = new EncryptionInfoProperty {
EncryptionAtRest = new EncryptionAtRestProperty {
DataVolumeKmsKeyId = "dataVolumeKmsKeyId"
},
EncryptionInTransit = new EncryptionInTransitProperty {
ClientBroker = "clientBroker",
InCluster = false
}
},
EnhancedMonitoring = "enhancedMonitoring",
LoggingInfo = new LoggingInfoProperty {
BrokerLogs = new BrokerLogsProperty {
CloudWatchLogs = new CloudWatchLogsProperty {
Enabled = false,
// the properties below are optional
LogGroup = "logGroup"
},
Firehose = new FirehoseProperty {
Enabled = false,
// the properties below are optional
DeliveryStream = "deliveryStream"
},
S3 = new S3Property {
Enabled = false,
// the properties below are optional
Bucket = "bucket",
Prefix = "prefix"
}
}
},
OpenMonitoring = new OpenMonitoringProperty {
Prometheus = new PrometheusProperty {
JmxExporter = new JmxExporterProperty {
EnabledInBroker = false
},
NodeExporter = new NodeExporterProperty {
EnabledInBroker = false
}
}
},
StorageMode = "storageMode",
Tags = new Dictionary<string, string> {
{ "tagsKey", "tags" }
}
};
Synopsis
Constructors
CfnClusterProps() |
Properties
BrokerNodeGroupInfo | Information about the broker nodes in the cluster. |
ClientAuthentication | VPC connection control settings for brokers. |
ClusterName | The name of the cluster. |
ConfigurationInfo | Represents the configuration that you want MSK to use for the cluster. |
CurrentVersion | The version of the cluster that you want to update. |
EncryptionInfo | Includes all encryption-related information. |
EnhancedMonitoring | Specifies the level of monitoring for the MSK cluster. |
KafkaVersion | The version of Apache Kafka. |
LoggingInfo | Logging Info details. |
NumberOfBrokerNodes | The number of broker nodes in the cluster. |
OpenMonitoring | The settings for open monitoring. |
StorageMode | This controls storage mode for supported storage tiers. |
Tags | Create tags when creating the cluster. |
Constructors
CfnClusterProps()
public CfnClusterProps()
Properties
BrokerNodeGroupInfo
Information about the broker nodes in the cluster.
public object BrokerNodeGroupInfo { get; set; }
Property Value
System.Object
Remarks
ClientAuthentication
VPC connection control settings for brokers.
public object ClientAuthentication { get; set; }
Property Value
System.Object
Remarks
ClusterName
The name of the cluster.
public string ClusterName { get; set; }
Property Value
System.String
Remarks
ConfigurationInfo
Represents the configuration that you want MSK to use for the cluster.
public object ConfigurationInfo { get; set; }
Property Value
System.Object
Remarks
CurrentVersion
The version of the cluster that you want to update.
public string CurrentVersion { get; set; }
Property Value
System.String
Remarks
EncryptionInfo
Includes all encryption-related information.
public object EncryptionInfo { get; set; }
Property Value
System.Object
Remarks
EnhancedMonitoring
Specifies the level of monitoring for the MSK cluster.
public string EnhancedMonitoring { get; set; }
Property Value
System.String
Remarks
The possible values are DEFAULT
, PER_BROKER
, and PER_TOPIC_PER_BROKER
.
KafkaVersion
The version of Apache Kafka.
public string KafkaVersion { get; set; }
Property Value
System.String
Remarks
You can use Amazon MSK to create clusters that use Apache Kafka versions 1.1.1 and 2.2.1.
LoggingInfo
Logging Info details.
public object LoggingInfo { get; set; }
Property Value
System.Object
Remarks
NumberOfBrokerNodes
The number of broker nodes in the cluster.
public double NumberOfBrokerNodes { get; set; }
Property Value
System.Double
Remarks
OpenMonitoring
The settings for open monitoring.
public object OpenMonitoring { get; set; }
Property Value
System.Object
Remarks
StorageMode
This controls storage mode for supported storage tiers.
public string StorageMode { get; set; }
Property Value
System.String
Remarks
Tags
Create tags when creating the cluster.
public IDictionary<string, string> Tags { get; set; }
Property Value
System.Collections.Generic.IDictionary<System.String, System.String>