CfnReplicatorMixinProps

class aws_cdk.mixins_preview.aws_msk.mixins.CfnReplicatorMixinProps(*, description=None, kafka_clusters=None, replication_info_list=None, replicator_name=None, service_execution_role_arn=None, tags=None)

Bases: object

Properties for CfnReplicatorPropsMixin.

Parameters:

description (Optional[str]) – A summary description of the replicator.
kafka_clusters (Union[IResolvable, Sequence[Union[IResolvable, KafkaClusterProperty, Dict[str, Any]]], None]) – Kafka Clusters to use in setting up sources / targets for replication.
replication_info_list (Union[IResolvable, Sequence[Union[IResolvable, ReplicationInfoProperty, Dict[str, Any]]], None]) – A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
replicator_name (Optional[str]) – The name of the replicator. Alpha-numeric characters with ‘-’ are allowed.
service_execution_role_arn (Optional[str]) – The ARN of the IAM role used by the replicator to access resources in the customer’s account (e.g source and target clusters).
tags (Optional[Sequence[Union[CfnTag, Dict[str, Any]]]]) – List of tags to attach to created Replicator.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-msk-replicator.html

ExampleMetadata:

fixture=_generated

Example:

# The code below shows an example of how to instantiate this type.
# The values are placeholders you should change.
from aws_cdk.mixins_preview.aws_msk import mixins as msk_mixins

cfn_replicator_mixin_props = msk_mixins.CfnReplicatorMixinProps(
    description="description",
    kafka_clusters=[msk_mixins.CfnReplicatorPropsMixin.KafkaClusterProperty(
        amazon_msk_cluster=msk_mixins.CfnReplicatorPropsMixin.AmazonMskClusterProperty(
            msk_cluster_arn="mskClusterArn"
        ),
        vpc_config=msk_mixins.CfnReplicatorPropsMixin.KafkaClusterClientVpcConfigProperty(
            security_group_ids=["securityGroupIds"],
            subnet_ids=["subnetIds"]
        )
    )],
    replication_info_list=[msk_mixins.CfnReplicatorPropsMixin.ReplicationInfoProperty(
        consumer_group_replication=msk_mixins.CfnReplicatorPropsMixin.ConsumerGroupReplicationProperty(
            consumer_groups_to_exclude=["consumerGroupsToExclude"],
            consumer_groups_to_replicate=["consumerGroupsToReplicate"],
            detect_and_copy_new_consumer_groups=False,
            synchronise_consumer_group_offsets=False
        ),
        source_kafka_cluster_arn="sourceKafkaClusterArn",
        target_compression_type="targetCompressionType",
        target_kafka_cluster_arn="targetKafkaClusterArn",
        topic_replication=msk_mixins.CfnReplicatorPropsMixin.TopicReplicationProperty(
            copy_access_control_lists_for_topics=False,
            copy_topic_configurations=False,
            detect_and_copy_new_topics=False,
            starting_position=msk_mixins.CfnReplicatorPropsMixin.ReplicationStartingPositionProperty(
                type="type"
            ),
            topic_name_configuration=msk_mixins.CfnReplicatorPropsMixin.ReplicationTopicNameConfigurationProperty(
                type="type"
            ),
            topics_to_exclude=["topicsToExclude"],
            topics_to_replicate=["topicsToReplicate"]
        )
    )],
    replicator_name="replicatorName",
    service_execution_role_arn="serviceExecutionRoleArn",
    tags=[CfnTag(
        key="key",
        value="value"
    )]
)