Package com.pulumi.aws.msk.inputs

Class ChannelIcebergDestinationArgs

  • public final class ChannelIcebergDestinationArgs
extends com.pulumi.resources.ResourceArgs

    • Method Detail

      • appendOnly

        public com.pulumi.core.Output<java.lang.Boolean> appendOnly()
        Returns:
        Whether the destination is append-only. Must be `true`; updates and deletes are not supported.

      • catalog

        public java.util.Optional<com.pulumi.core.Output<ChannelIcebergDestinationCatalogArgs>> catalog()
        Returns:
        AWS Glue Data Catalog and S3 Tables warehouse used by the destination. See `catalog` Block below.

      • compressionType

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> compressionType()
        Returns:
        Compression codec for Iceberg table data files. Defaults to `ZSTD`.

      • dataFreshnessInSeconds

        public java.util.Optional<com.pulumi.core.Output<java.lang.Integer>> dataFreshnessInSeconds()
        Returns:
        Maximum time, in seconds, that records buffer in MSK before being flushed to the destination. Valid values are between `300` and `900`. Defaults to `600`. Can be updated in place without recreating the channel.

      • deadLetterQueueS3

        public com.pulumi.core.Output<ChannelIcebergDestinationDeadLetterQueueS3Args> deadLetterQueueS3()
        Returns:
        Amazon S3 bucket and prefix where MSK writes records that fail to deliver. See `deadLetterQueueS3` Block below.

      • schemaEvolution

        public com.pulumi.core.Output<ChannelIcebergDestinationSchemaEvolutionArgs> schemaEvolution()
        Returns:
        Configuration controlling whether the destination table's schema is evolved to match incoming records. See `schemaEvolution` Block below.

      • serviceExecutionRoleArn

        public com.pulumi.core.Output<java.lang.String> serviceExecutionRoleArn()
        Returns:
        ARN of the IAM role that MSK assumes to access the destination table, the AWS Glue Data Catalog, and the dead-letter Amazon S3 bucket.

      • tableCreation

        public com.pulumi.core.Output<ChannelIcebergDestinationTableCreationArgs> tableCreation()
        Returns:
        Configuration controlling whether MSK creates the destination table if it does not already exist. See `tableCreation` Block below. The following arguments are optional: