interface IcebergDestinationConfigurationProperty
| Language | Type name |
|---|---|
.NET | Amazon.CDK.AWS.MSK.CfnChannel.IcebergDestinationConfigurationProperty |
Go | github.com/aws/aws-cdk-go/awscdk/v2/awsmsk#CfnChannel_IcebergDestinationConfigurationProperty |
Java | software.amazon.awscdk.services.msk.CfnChannel.IcebergDestinationConfigurationProperty |
Python | aws_cdk.aws_msk.CfnChannel.IcebergDestinationConfigurationProperty |
TypeScript | aws-cdk-lib » aws_msk » CfnChannel » IcebergDestinationConfigurationProperty |
Iceberg destination configuration.
Example
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import { aws_msk as msk } from 'aws-cdk-lib';
const icebergDestinationConfigurationProperty: msk.CfnChannel.IcebergDestinationConfigurationProperty = {
appendOnly: false,
deadLetterQueueS3: {
bucketArn: 'bucketArn',
errorOutputPrefix: 'errorOutputPrefix',
// the properties below are optional
expectedBucketOwner: 'expectedBucketOwner',
},
destinationTableList: [{
destinationDatabaseName: 'destinationDatabaseName',
destinationTableName: 'destinationTableName',
// the properties below are optional
partitionSpec: {
partitionStrategy: 'partitionStrategy',
// the properties below are optional
sourceList: [{
sourceName: 'sourceName',
}],
},
}],
schemaEvolution: {
enableSchemaEvolution: false,
},
serviceExecutionRoleArn: 'serviceExecutionRoleArn',
tableCreation: {
enableTableCreation: false,
},
// the properties below are optional
catalog: {
catalogArn: 'catalogArn',
warehouseLocation: 'warehouseLocation',
},
compressionType: 'compressionType',
dataFreshnessInSeconds: 123,
};
Properties
| Name | Type | Description |
|---|---|---|
| append | boolean | IResolvable | Append only mode. |
| dead | IResolvable | Dead | Dead letter queue S3 configuration of the destination. |
| destination | IResolvable | (IResolvable | Destination)[] | List of destination tables. |
| schema | IResolvable | Schema | Schema evolution configuration of the destination. |
| service | string | The Amazon Resource Name (ARN) of an IAM role used by MSK to access the table. |
| table | IResolvable | Table | Table creation configuration of the destination. |
| catalog? | IResolvable | Catalog | Catalog configuration of the destination. |
| compression | string | Compression codec for Iceberg table data files. |
| data | number | Data freshness in seconds. |
appendOnly
Type:
boolean | IResolvable
Append only mode.
deadLetterQueueS3
Type:
IResolvable | Dead
Dead letter queue S3 configuration of the destination.
destinationTableList
Type:
IResolvable | (IResolvable | Destination)[]
List of destination tables.
schemaEvolution
Type:
IResolvable | Schema
Schema evolution configuration of the destination.
serviceExecutionRoleArn
Type:
string
The Amazon Resource Name (ARN) of an IAM role used by MSK to access the table.
tableCreation
Type:
IResolvable | Table
Table creation configuration of the destination.
catalog?
Type:
IResolvable | Catalog
(optional)
Catalog configuration of the destination.
compressionType?
Type:
string
(optional)
Compression codec for Iceberg table data files.
Defaults to ZSTD.
dataFreshnessInSeconds?
Type:
number
(optional)
Data freshness in seconds.

.NET
Go
Java
Python
TypeScript