kafka/aws.sdk.kotlin.services.kafka.model/CreateChannelRequest/Builder

Builder

Properties

var channelName: String?

The name of the channel. Must be unique within the cluster.

var clusterArn: String?

The Amazon Resource Name (ARN) that uniquely identifies the cluster.

encryptionConfiguration

var encryptionConfiguration: EncryptionConfiguration?

The encryption configuration applied to the channel.

icebergDestinationConfiguration

var icebergDestinationConfiguration: IcebergDestinationConfiguration?

The Apache Iceberg destination for the channel. Mutually exclusive with s3DestinationConfiguration.

var loggingInfo: ChannelLoggingInfo?

The destinations to which the channel publishes operational logs.

s3DestinationConfiguration

var s3DestinationConfiguration: S3DestinationConfiguration?

The Amazon S3 destination for the channel. Mutually exclusive with icebergDestinationConfiguration.

var tags: Map<String, String>?

The tags attached to the channel.

topicConfigurationList

var topicConfigurationList: List<TopicConfiguration>?

The list of topic configurations for the channel. Currently exactly one topic must be specified.

Functions

encryptionConfiguration

fun encryptionConfiguration(block: EncryptionConfiguration.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.kafka.model.EncryptionConfiguration inside the given block

icebergDestinationConfiguration

fun icebergDestinationConfiguration(block: IcebergDestinationConfiguration.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.kafka.model.IcebergDestinationConfiguration inside the given block

fun loggingInfo(block: ChannelLoggingInfo.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.kafka.model.ChannelLoggingInfo inside the given block

s3DestinationConfiguration

fun s3DestinationConfiguration(block: S3DestinationConfiguration.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.kafka.model.S3DestinationConfiguration inside the given block