Package software.amazon.awscdk.cfnpropertymixins.services.msk

Interface CfnReplicatorMixinProps

All Superinterfaces:
software.amazon.jsii.JsiiSerializable
All Known Implementing Classes:
CfnReplicatorMixinProps.Jsii$Proxy
@Generated(value="jsii-pacmak/1.127.0 (build 2117ad5)", date="2026-04-24T20:29:47.454Z") @Stability(Stable) public interface CfnReplicatorMixinProps extends software.amazon.jsii.JsiiSerializable
Properties for CfnReplicatorPropsMixin.

Example: 

 // The code below shows an example of how to instantiate this type.
 // The values are placeholders you should change.
 import software.amazon.awscdk.cfnpropertymixins.services.msk.*;
 CfnReplicatorMixinProps cfnReplicatorMixinProps = CfnReplicatorMixinProps.builder()
         .description("description")
         .kafkaClusters(List.of(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")
                         .rootCaCertificate("rootCaCertificate")
                         .build())
                 .vpcConfig(KafkaClusterClientVpcConfigProperty.builder()
                         .securityGroupIds(List.of("securityGroupIds"))
                         .subnetIds(List.of("subnetIds"))
                         .build())
                 .build()))
         .logDelivery(LogDeliveryProperty.builder()
                 .replicatorLogDelivery(ReplicatorLogDeliveryProperty.builder()
                         .cloudWatchLogs(CloudWatchLogsProperty.builder()
                                 .enabled(false)
                                 .logGroup("logGroup")
                                 .build())
                         .firehose(FirehoseProperty.builder()
                                 .deliveryStream("deliveryStream")
                                 .enabled(false)
                                 .build())
                         .s3(S3Property.builder()
                                 .bucket("bucket")
                                 .enabled(false)
                                 .prefix("prefix")
                                 .build())
                         .build())
                 .build())
         .replicationInfoList(List.of(ReplicationInfoProperty.builder()
                 .consumerGroupReplication(ConsumerGroupReplicationProperty.builder()
                         .consumerGroupOffsetSyncMode("consumerGroupOffsetSyncMode")
                         .consumerGroupsToExclude(List.of("consumerGroupsToExclude"))
                         .consumerGroupsToReplicate(List.of("consumerGroupsToReplicate"))
                         .detectAndCopyNewConsumerGroups(false)
                         .synchroniseConsumerGroupOffsets(false)
                         .build())
                 .sourceKafkaClusterArn("sourceKafkaClusterArn")
                 .sourceKafkaClusterId("sourceKafkaClusterId")
                 .targetCompressionType("targetCompressionType")
                 .targetKafkaClusterArn("targetKafkaClusterArn")
                 .targetKafkaClusterId("targetKafkaClusterId")
                 .topicReplication(TopicReplicationProperty.builder()
                         .copyAccessControlListsForTopics(false)
                         .copyTopicConfigurations(false)
                         .detectAndCopyNewTopics(false)
                         .startingPosition(ReplicationStartingPositionProperty.builder()
                                 .type("type")
                                 .build())
                         .topicNameConfiguration(ReplicationTopicNameConfigurationProperty.builder()
                                 .type("type")
                                 .build())
                         .topicsToExclude(List.of("topicsToExclude"))
                         .topicsToReplicate(List.of("topicsToReplicate"))
                         .build())
                 .build()))
         .replicatorName("replicatorName")
         .serviceExecutionRoleArn("serviceExecutionRoleArn")
         .tags(List.of(CfnTag.builder()
                 .key("key")
                 .value("value")
                 .build()))
         .build();

See Also: