Package com.pulumi.aws.msk.outputs

Class ChannelIcebergDestination

java.lang.Object

com.pulumi.aws.msk.outputs.ChannelIcebergDestination

public final class ChannelIcebergDestination
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ChannelIcebergDestination.Builder

Method Summary

Modifier and Type	Method	Description
java.lang.Boolean	appendOnly()
static ChannelIcebergDestination.Builder	builder()
static ChannelIcebergDestination.Builder	builder(ChannelIcebergDestination defaults)
java.util.Optional<ChannelIcebergDestinationCatalog>	catalog()
java.util.Optional<java.lang.String>	compressionType()
java.util.Optional<java.lang.Integer>	dataFreshnessInSeconds()
ChannelIcebergDestinationDeadLetterQueueS3	deadLetterQueueS3()
ChannelIcebergDestinationDestinationTable	destinationTable()
ChannelIcebergDestinationSchemaEvolution	schemaEvolution()
java.lang.String	serviceExecutionRoleArn()
ChannelIcebergDestinationTableCreation	tableCreation()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

appendOnly

public 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<ChannelIcebergDestinationCatalog> catalog()

Returns:

AWS Glue Data Catalog and S3 Tables warehouse used by the destination. See `catalog` Block below.

compressionType

public java.util.Optional<java.lang.String> compressionType()

Returns:

Compression codec for Iceberg table data files. Defaults to `ZSTD`.

dataFreshnessInSeconds

public java.util.Optional<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 ChannelIcebergDestinationDeadLetterQueueS3 deadLetterQueueS3()

Returns:

Amazon S3 bucket and prefix where MSK writes records that fail to deliver. See `deadLetterQueueS3` Block below.

destinationTable

public ChannelIcebergDestinationDestinationTable destinationTable()

Returns:

Destination Iceberg table. See `destinationTable` Block below.

schemaEvolution

public ChannelIcebergDestinationSchemaEvolution schemaEvolution()

Returns:

Configuration controlling whether the destination table's schema is evolved to match incoming records. See `schemaEvolution` Block below.

serviceExecutionRoleArn

public 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 ChannelIcebergDestinationTableCreation 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:

builder

public static ChannelIcebergDestination.Builder builder()

builder

public static ChannelIcebergDestination.Builder builder(ChannelIcebergDestination defaults)