Package software.amazon.awscdk.services.msk

Interface CfnReplicatorProps

All Superinterfaces:
software.amazon.jsii.JsiiSerializable
All Known Implementing Classes:
CfnReplicatorProps.Jsii$Proxy
@Generated(value="jsii-pacmak/1.98.0 (build 00b106d)", date="2024-05-08T21:35:10.056Z") @Stability(Stable) public interface CfnReplicatorProps extends software.amazon.jsii.JsiiSerializable
Properties for defining a CfnReplicator.

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.*;
 CfnReplicatorProps cfnReplicatorProps = CfnReplicatorProps.builder()
         .kafkaClusters(List.of(KafkaClusterProperty.builder()
                 .amazonMskCluster(AmazonMskClusterProperty.builder()
                         .mskClusterArn("mskClusterArn")
                         .build())
                 .vpcConfig(KafkaClusterClientVpcConfigProperty.builder()
                         .subnetIds(List.of("subnetIds"))
                         // the properties below are optional
                         .securityGroupIds(List.of("securityGroupIds"))
                         .build())
                 .build()))
         .replicationInfoList(List.of(ReplicationInfoProperty.builder()
                 .consumerGroupReplication(ConsumerGroupReplicationProperty.builder()
                         .consumerGroupsToReplicate(List.of("consumerGroupsToReplicate"))
                         // the properties below are optional
                         .consumerGroupsToExclude(List.of("consumerGroupsToExclude"))
                         .detectAndCopyNewConsumerGroups(false)
                         .synchroniseConsumerGroupOffsets(false)
                         .build())
                 .sourceKafkaClusterArn("sourceKafkaClusterArn")
                 .targetCompressionType("targetCompressionType")
                 .targetKafkaClusterArn("targetKafkaClusterArn")
                 .topicReplication(TopicReplicationProperty.builder()
                         .topicsToReplicate(List.of("topicsToReplicate"))
                         // the properties below are optional
                         .copyAccessControlListsForTopics(false)
                         .copyTopicConfigurations(false)
                         .detectAndCopyNewTopics(false)
                         .startingPosition(ReplicationStartingPositionProperty.builder()
                                 .type("type")
                                 .build())
                         .topicsToExclude(List.of("topicsToExclude"))
                         .build())
                 .build()))
         .replicatorName("replicatorName")
         .serviceExecutionRoleArn("serviceExecutionRoleArn")
         // the properties below are optional
         .currentVersion("currentVersion")
         .description("description")
         .tags(List.of(CfnTag.builder()
                 .key("key")
                 .value("value")
                 .build()))
         .build();

See Also: