CfnReplicatorMixinProps

class aws_cdk.cfn_property_mixins.aws_msk.CfnReplicatorMixinProps(*, description=None, kafka_clusters=None, log_delivery=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.
log_delivery (Union[IResolvable, LogDeliveryProperty, Dict[str, Any], None]) – Configuration for log delivery for the replicator.
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:

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

cfn_replicator_mixin_props = msk.CfnReplicatorMixinProps(
    description="description",
    kafka_clusters=[msk.CfnReplicatorPropsMixin.KafkaClusterProperty(
        amazon_msk_cluster=msk.CfnReplicatorPropsMixin.AmazonMskClusterProperty(
            msk_cluster_arn="mskClusterArn"
        ),
        apache_kafka_cluster=msk.CfnReplicatorPropsMixin.ApacheKafkaClusterProperty(
            apache_kafka_cluster_id="apacheKafkaClusterId",
            bootstrap_broker_string="bootstrapBrokerString"
        ),
        client_authentication=msk.CfnReplicatorPropsMixin.KafkaClusterClientAuthenticationProperty(
            sasl_scram=msk.CfnReplicatorPropsMixin.KafkaClusterSaslScramAuthenticationProperty(
                mechanism="mechanism",
                secret_arn="secretArn"
            )
        ),
        encryption_in_transit=msk.CfnReplicatorPropsMixin.KafkaClusterEncryptionInTransitProperty(
            encryption_type="encryptionType",
            root_ca_certificate="rootCaCertificate"
        ),
        vpc_config=msk.CfnReplicatorPropsMixin.KafkaClusterClientVpcConfigProperty(
            security_group_ids=["securityGroupIds"],
            subnet_ids=["subnetIds"]
        )
    )],
    log_delivery=msk.CfnReplicatorPropsMixin.LogDeliveryProperty(
        replicator_log_delivery=msk.CfnReplicatorPropsMixin.ReplicatorLogDeliveryProperty(
            cloud_watch_logs=msk.CfnReplicatorPropsMixin.CloudWatchLogsProperty(
                enabled=False,
                log_group="logGroup"
            ),
            firehose=msk.CfnReplicatorPropsMixin.FirehoseProperty(
                delivery_stream="deliveryStream",
                enabled=False
            ),
            s3=msk.CfnReplicatorPropsMixin.S3Property(
                bucket="bucket",
                enabled=False,
                prefix="prefix"
            )
        )
    ),
    replication_info_list=[msk.CfnReplicatorPropsMixin.ReplicationInfoProperty(
        consumer_group_replication=msk.CfnReplicatorPropsMixin.ConsumerGroupReplicationProperty(
            consumer_group_offset_sync_mode="consumerGroupOffsetSyncMode",
            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",
        source_kafka_cluster_id="sourceKafkaClusterId",
        target_compression_type="targetCompressionType",
        target_kafka_cluster_arn="targetKafkaClusterArn",
        target_kafka_cluster_id="targetKafkaClusterId",
        topic_replication=msk.CfnReplicatorPropsMixin.TopicReplicationProperty(
            copy_access_control_lists_for_topics=False,
            copy_topic_configurations=False,
            detect_and_copy_new_topics=False,
            starting_position=msk.CfnReplicatorPropsMixin.ReplicationStartingPositionProperty(
                type="type"
            ),
            topic_name_configuration=msk.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"
    )]
)