Package software.amazon.awscdk.services.msk

Interface CfnReplicator.KafkaClusterProperty

All Superinterfaces:
software.amazon.jsii.JsiiSerializable
All Known Implementing Classes:
CfnReplicator.KafkaClusterProperty.Jsii$Proxy
Enclosing class:
CfnReplicator
@Stability(Stable) public static interface CfnReplicator.KafkaClusterProperty extends software.amazon.jsii.JsiiSerializable
Information about Kafka Cluster to be used as source / target for replication.

Example: 

 // The code below shows an example of how to instantiate this type.
 // The values are placeholders you should change.
 import software.amazon.awscdk.services.msk.*;
 KafkaClusterProperty kafkaClusterProperty = KafkaClusterProperty.builder()
         .amazonMskCluster(AmazonMskClusterProperty.builder()
                 .mskClusterArn("mskClusterArn")
                 .build())
         .apacheKafkaCluster(ApacheKafkaClusterProperty.builder()
                 .apacheKafkaClusterId("apacheKafkaClusterId")
                 .bootstrapBrokerString("bootstrapBrokerString")
                 .build())
         .clientAuthentication(KafkaClusterClientAuthenticationProperty.builder()
                 .saslScram(KafkaClusterSaslScramAuthenticationProperty.builder()
                         .mechanism("mechanism")
                         .secretArn("secretArn")
                         .build())
                 .build())
         .encryptionInTransit(KafkaClusterEncryptionInTransitProperty.builder()
                 .encryptionType("encryptionType")
                 // the properties below are optional
                 .rootCaCertificate("rootCaCertificate")
                 .build())
         .vpcConfig(KafkaClusterClientVpcConfigProperty.builder()
                 .subnetIds(List.of("subnetIds"))
                 // the properties below are optional
                 .securityGroupIds(List.of("securityGroupIds"))
                 .build())
         .build();

See Also: