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

CreateChannelRequest

class CreateChannelRequest

Creates a Channel that streams records from an Amazon MSK Express cluster topic to Amazon S3 or Apache Iceberg.

Types

object Companion

Properties

val channelName: String?

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

val clusterArn: String?

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

encryptionConfiguration

val encryptionConfiguration: EncryptionConfiguration?

The encryption configuration applied to the channel.

icebergDestinationConfiguration

val icebergDestinationConfiguration: IcebergDestinationConfiguration?

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

val loggingInfo: ChannelLoggingInfo?

The destinations to which the channel publishes operational logs.

s3DestinationConfiguration

val s3DestinationConfiguration: S3DestinationConfiguration?

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

val tags: Map<String, String>?

The tags attached to the channel.

topicConfigurationList

val topicConfigurationList: List<TopicConfiguration>?

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

Functions

inline fun copy(block: CreateChannelRequest.Builder.() -> Unit = {}): CreateChannelRequest

open operator override fun equals(other: Any?): Boolean

open override fun hashCode(): Int

open override fun toString(): String