Class: Aws::Kafka::Types::IcebergDestinationConfiguration

Inherits:

Struct

• Object
• Struct
• Aws::Kafka::Types::IcebergDestinationConfiguration

Includes:

Structure

Defined in:

lib/aws-sdk-kafka/types.rb

Overview

Configuration of an Apache Iceberg destination for a channel.

See Also:

• AWS API Documentation

Constant Summary

SENSITIVE =

[]

Instance Attribute Summary

• #append_only ⇒ Boolean

  Whether the destination is append-only.

• #catalog ⇒ Types::Catalog

  The AWS Glue Data Catalog and S3 Tables warehouse used by the destination.

• #compression_type ⇒ String

  The compression codec for Iceberg table data files.

• #data_freshness_in_seconds ⇒ Integer

  The maximum time, in seconds, that records buffer in MSK before being flushed to the destination.

• #dead_letter_queue_s3 ⇒ Types::DeadLetterQueueS3

  The Amazon S3 bucket and prefix where MSK writes records that fail to deliver.

• #destination_table_list ⇒ Array<Types::DestinationTable>

  The destination Iceberg tables.

• #schema_evolution ⇒ Types::SchemaEvolution

  Configuration controlling whether the destination table's schema is evolved to match incoming records.

• #service_execution_role_arn ⇒ String

  The Amazon Resource Name (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.

• #table_creation ⇒ Types::TableCreation

  Configuration controlling whether MSK creates the destination table if it does not already exist.

Instance Attribute Details

#append_only ⇒ Boolean

Whether the destination is append-only. Must be true; updates and deletes are not supported.

Returns:

• (Boolean)

# File 'lib/aws-sdk-kafka/types.rb', line 2731

class IcebergDestinationConfiguration < Struct.new(
  :append_only,
  :catalog,
  :data_freshness_in_seconds,
  :dead_letter_queue_s3,
  :destination_table_list,
  :schema_evolution,
  :service_execution_role_arn,
  :table_creation,
  :compression_type)
  SENSITIVE = []
  include Aws::Structure
end

#catalog ⇒ Types::Catalog

The AWS Glue Data Catalog and S3 Tables warehouse used by the destination.

Returns:

• (Types::Catalog)

# File 'lib/aws-sdk-kafka/types.rb', line 2731

class IcebergDestinationConfiguration < Struct.new(
  :append_only,
  :catalog,
  :data_freshness_in_seconds,
  :dead_letter_queue_s3,
  :destination_table_list,
  :schema_evolution,
  :service_execution_role_arn,
  :table_creation,
  :compression_type)
  SENSITIVE = []
  include Aws::Structure
end

#compression_type ⇒ String

The compression codec for Iceberg table data files. Defaults to ZSTD.

Returns:

• (String)

# File 'lib/aws-sdk-kafka/types.rb', line 2731

class IcebergDestinationConfiguration < Struct.new(
  :append_only,
  :catalog,
  :data_freshness_in_seconds,
  :dead_letter_queue_s3,
  :destination_table_list,
  :schema_evolution,
  :service_execution_role_arn,
  :table_creation,
  :compression_type)
  SENSITIVE = []
  include Aws::Structure
end

#data_freshness_in_seconds ⇒ Integer

The maximum time, in seconds, that records buffer in MSK before being flushed to the destination. Allowed range: 300 to 900. Default: 600.

Returns:

• (Integer)

# File 'lib/aws-sdk-kafka/types.rb', line 2731

class IcebergDestinationConfiguration < Struct.new(
  :append_only,
  :catalog,
  :data_freshness_in_seconds,
  :dead_letter_queue_s3,
  :destination_table_list,
  :schema_evolution,
  :service_execution_role_arn,
  :table_creation,
  :compression_type)
  SENSITIVE = []
  include Aws::Structure
end

#dead_letter_queue_s3 ⇒ Types::DeadLetterQueueS3

The Amazon S3 bucket and prefix where MSK writes records that fail to deliver.

Returns:

• (Types::DeadLetterQueueS3)

# File 'lib/aws-sdk-kafka/types.rb', line 2731

class IcebergDestinationConfiguration < Struct.new(
  :append_only,
  :catalog,
  :data_freshness_in_seconds,
  :dead_letter_queue_s3,
  :destination_table_list,
  :schema_evolution,
  :service_execution_role_arn,
  :table_creation,
  :compression_type)
  SENSITIVE = []
  include Aws::Structure
end

#destination_table_list ⇒ Array<Types::DestinationTable>

The destination Iceberg tables. Currently exactly one table must be specified.

Returns:

• (Array<Types::DestinationTable>)

# File 'lib/aws-sdk-kafka/types.rb', line 2731

class IcebergDestinationConfiguration < Struct.new(
  :append_only,
  :catalog,
  :data_freshness_in_seconds,
  :dead_letter_queue_s3,
  :destination_table_list,
  :schema_evolution,
  :service_execution_role_arn,
  :table_creation,
  :compression_type)
  SENSITIVE = []
  include Aws::Structure
end

#schema_evolution ⇒ Types::SchemaEvolution

Configuration controlling whether the destination table's schema is evolved to match incoming records.

Returns:

• (Types::SchemaEvolution)

# File 'lib/aws-sdk-kafka/types.rb', line 2731

class IcebergDestinationConfiguration < Struct.new(
  :append_only,
  :catalog,
  :data_freshness_in_seconds,
  :dead_letter_queue_s3,
  :destination_table_list,
  :schema_evolution,
  :service_execution_role_arn,
  :table_creation,
  :compression_type)
  SENSITIVE = []
  include Aws::Structure
end

#service_execution_role_arn ⇒ String

The Amazon Resource Name (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.

Returns:

• (String)

# File 'lib/aws-sdk-kafka/types.rb', line 2731

class IcebergDestinationConfiguration < Struct.new(
  :append_only,
  :catalog,
  :data_freshness_in_seconds,
  :dead_letter_queue_s3,
  :destination_table_list,
  :schema_evolution,
  :service_execution_role_arn,
  :table_creation,
  :compression_type)
  SENSITIVE = []
  include Aws::Structure
end

#table_creation ⇒ Types::TableCreation

Configuration controlling whether MSK creates the destination table if it does not already exist.

Returns:

• (Types::TableCreation)

# File 'lib/aws-sdk-kafka/types.rb', line 2731

class IcebergDestinationConfiguration < Struct.new(
  :append_only,
  :catalog,
  :data_freshness_in_seconds,
  :dead_letter_queue_s3,
  :destination_table_list,
  :schema_evolution,
  :service_execution_role_arn,
  :table_creation,
  :compression_type)
  SENSITIVE = []
  include Aws::Structure
end