CfnChannelMixinProps

class aws_cdk.cfn_property_mixins.aws_msk.CfnChannelMixinProps(*, channel_name=None, cluster_arn=None, encryption_configuration=None, iceberg_destination_configuration=None, logging_info=None, s3_destination_configuration=None, tags=None, topic_configuration_list=None)

Bases: object

Properties for CfnChannelPropsMixin.

Parameters:

channel_name (Optional[str]) – Name of the channel.
cluster_arn (Optional[str]) – The Amazon Resource Name (ARN) of the cluster.
encryption_configuration (Union[IResolvable, EncryptionConfigurationProperty, Dict[str, Any], None]) – Encryption configuration.
iceberg_destination_configuration (Union[IResolvable, IcebergDestinationConfigurationProperty, Dict[str, Any], None]) – Iceberg destination configuration.
logging_info (Union[IResolvable, ChannelLoggingInfoProperty, Dict[str, Any], None]) – Log configuration details for Channel.
s3_destination_configuration (Union[IResolvable, S3DestinationConfigurationProperty, Dict[str, Any], None]) – S3 destination configuration.
tags (Optional[Mapping[str, str]]) – Tags attached to the channel.
topic_configuration_list (Union[IResolvable, Sequence[Union[IResolvable, TopicConfigurationProperty, Dict[str, Any]]], None]) – Topic configuration.

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-msk-channel.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.cfn_property_mixins import aws_msk as msk

cfn_channel_mixin_props = msk.CfnChannelMixinProps(
    channel_name="channelName",
    cluster_arn="clusterArn",
    encryption_configuration=msk.CfnChannelPropsMixin.EncryptionConfigurationProperty(
        kms_key_arn="kmsKeyArn"
    ),
    iceberg_destination_configuration=msk.CfnChannelPropsMixin.IcebergDestinationConfigurationProperty(
        append_only=False,
        catalog=msk.CfnChannelPropsMixin.CatalogProperty(
            catalog_arn="catalogArn",
            warehouse_location="warehouseLocation"
        ),
        compression_type="compressionType",
        data_freshness_in_seconds=123,
        dead_letter_queue_s3=msk.CfnChannelPropsMixin.DeadLetterQueueS3Property(
            bucket_arn="bucketArn",
            error_output_prefix="errorOutputPrefix",
            expected_bucket_owner="expectedBucketOwner"
        ),
        destination_table_list=[msk.CfnChannelPropsMixin.DestinationTableProperty(
            destination_database_name="destinationDatabaseName",
            destination_table_name="destinationTableName",
            partition_spec=msk.CfnChannelPropsMixin.PartitionSpecProperty(
                partition_strategy="partitionStrategy",
                source_list=[msk.CfnChannelPropsMixin.PartitionSourceProperty(
                    source_name="sourceName"
                )]
            )
        )],
        schema_evolution=msk.CfnChannelPropsMixin.SchemaEvolutionProperty(
            enable_schema_evolution=False
        ),
        service_execution_role_arn="serviceExecutionRoleArn",
        table_creation=msk.CfnChannelPropsMixin.TableCreationProperty(
            enable_table_creation=False
        )
    ),
    logging_info=msk.CfnChannelPropsMixin.ChannelLoggingInfoProperty(
        cloud_watch_logs=msk.CfnChannelPropsMixin.CloudWatchLogsLogDestinationProperty(
            enabled=False,
            log_group="logGroup"
        ),
        firehose=msk.CfnChannelPropsMixin.FirehoseLogDestinationProperty(
            delivery_stream="deliveryStream",
            enabled=False
        ),
        s3=msk.CfnChannelPropsMixin.S3LogDestinationProperty(
            bucket="bucket",
            enabled=False,
            prefix="prefix"
        )
    ),
    s3_destination_configuration=msk.CfnChannelPropsMixin.S3DestinationConfigurationProperty(
        data_freshness_in_seconds=123,
        dead_letter_queue_s3=msk.CfnChannelPropsMixin.DeadLetterQueueS3Property(
            bucket_arn="bucketArn",
            error_output_prefix="errorOutputPrefix",
            expected_bucket_owner="expectedBucketOwner"
        ),
        service_execution_role_arn="serviceExecutionRoleArn",
        storage=msk.CfnChannelPropsMixin.S3StorageProperty(
            bucket_arn="bucketArn",
            compression_type="compressionType",
            expected_bucket_owner="expectedBucketOwner",
            output_key_template="outputKeyTemplate",
            output_prefix="outputPrefix",
            storage_class="storageClass"
        )
    ),
    tags={
        "tags_key": "tags"
    },
    topic_configuration_list=[msk.CfnChannelPropsMixin.TopicConfigurationProperty(
        record_converter=msk.CfnChannelPropsMixin.RecordConverterProperty(
            value_converter="valueConverter"
        ),
        record_schema=msk.CfnChannelPropsMixin.RecordSchemaProperty(
            gsr_arn="gsrArn"
        ),
        topic_arn="topicArn"
    )]
)