Package-level declarations

Types

Link copied to clipboard
data class ClusterBrokerLogs(val cloudWatchLogs: ClusterCloudWatchLogs? = null, val firehose: ClusterFirehose? = null, val s3: ClusterS3? = null)
Link copied to clipboard
data class ClusterBrokerNodeGroupInfo(val brokerAzDistribution: String? = null, val clientSubnets: List<String>, val connectivityInfo: ClusterConnectivityInfo? = null, val instanceType: String, val securityGroups: List<String>? = null, val storageInfo: ClusterStorageInfo? = null)
Link copied to clipboard
data class ClusterClientAuthentication(val sasl: ClusterSasl? = null, val tls: ClusterTls? = null, val unauthenticated: ClusterUnauthenticated? = null)
Link copied to clipboard
data class ClusterCloudWatchLogs(val enabled: Boolean, val logGroup: String? = null)
Link copied to clipboard
data class ClusterConfigurationInfo(val arn: String, val revision: Int)
Link copied to clipboard
data class ClusterConnectivityInfo(val publicAccess: ClusterPublicAccess? = null, val vpcConnectivity: ClusterVpcConnectivity? = null)
Link copied to clipboard
data class ClusterEbsStorageInfo(val provisionedThroughput: ClusterProvisionedThroughput? = null, val volumeSize: Int? = null)
Link copied to clipboard
data class ClusterEncryptionAtRest(val dataVolumeKmsKeyId: String)
Link copied to clipboard
data class ClusterEncryptionInfo(val encryptionAtRest: ClusterEncryptionAtRest? = null, val encryptionInTransit: ClusterEncryptionInTransit? = null)
Link copied to clipboard
data class ClusterEncryptionInTransit(val clientBroker: ClusterEncryptionInTransitClientBroker? = null, val inCluster: Boolean? = null)
Link copied to clipboard
data class ClusterFirehose(val deliveryStream: String? = null, val enabled: Boolean)
Link copied to clipboard
data class ClusterIam(val enabled: Boolean)
Link copied to clipboard
data class ClusterJmxExporter(val enabledInBroker: Boolean)
Link copied to clipboard
data class ClusterLoggingInfo(val brokerLogs: ClusterBrokerLogs)
Link copied to clipboard
data class ClusterNodeExporter(val enabledInBroker: Boolean)
Link copied to clipboard
data class ClusterOpenMonitoring(val prometheus: ClusterPrometheus)
Link copied to clipboard
data class ClusterPrometheus(val jmxExporter: ClusterJmxExporter? = null, val nodeExporter: ClusterNodeExporter? = null)
Link copied to clipboard
data class ClusterProvisionedThroughput(val enabled: Boolean? = null, val volumeThroughput: Int? = null)
Link copied to clipboard
data class ClusterPublicAccess(val type: String? = null)
Link copied to clipboard
data class ClusterS3(val bucket: String? = null, val enabled: Boolean, val prefix: String? = null)
Link copied to clipboard
data class ClusterSasl(val iam: ClusterIam? = null, val scram: ClusterScram? = null)
Link copied to clipboard
data class ClusterScram(val enabled: Boolean)
Link copied to clipboard
data class ClusterStorageInfo(val ebsStorageInfo: ClusterEbsStorageInfo? = null)
Link copied to clipboard
data class ClusterTls(val certificateAuthorityArnList: List<String>? = null, val enabled: Boolean? = null)
Link copied to clipboard
data class ClusterUnauthenticated(val enabled: Boolean)
Link copied to clipboard
data class ClusterVpcConnectivity(val clientAuthentication: ClusterVpcConnectivityClientAuthentication? = null)
Link copied to clipboard
data class ClusterVpcConnectivityIam(val enabled: Boolean)
Link copied to clipboard
Link copied to clipboard
data class ClusterVpcConnectivityScram(val enabled: Boolean)
Link copied to clipboard
data class ClusterVpcConnectivityTls(val enabled: Boolean)
Link copied to clipboard
data class ConfigurationLatestRevision(val creationTime: String? = null, val description: String? = null, val revision: Int? = null)
Link copied to clipboard
data class GetBatchScramSecretResult(val secretArnList: List<String>? = null)
Link copied to clipboard
data class GetClusterPolicyResult(val currentVersion: String? = null, val policy: Any? = null)
Link copied to clipboard
data class GetClusterResult(val arn: String? = null, val brokerNodeGroupInfo: ClusterBrokerNodeGroupInfo? = null, val clientAuthentication: ClusterClientAuthentication? = null, val configurationInfo: ClusterConfigurationInfo? = null, val currentVersion: String? = null, val encryptionInfo: ClusterEncryptionInfo? = null, val enhancedMonitoring: ClusterEnhancedMonitoring? = null, val kafkaVersion: String? = null, val loggingInfo: ClusterLoggingInfo? = null, val numberOfBrokerNodes: Int? = null, val openMonitoring: ClusterOpenMonitoring? = null, val storageMode: ClusterStorageMode? = null, val tags: Map<String, String>? = null)
Link copied to clipboard
data class GetConfigurationResult(val arn: String? = null, val description: String? = null, val latestRevision: ConfigurationLatestRevision? = null)
Link copied to clipboard
data class GetReplicatorResult(val currentVersion: String? = null, val replicationInfoList: List<ReplicatorReplicationInfo>? = null, val replicatorArn: String? = null, val tags: List<Tag>? = null)
Link copied to clipboard
data class GetServerlessClusterResult(val arn: String? = null)
Link copied to clipboard
data class GetVpcConnectionResult(val arn: String? = null, val tags: Map<String, String>? = null)
Link copied to clipboard
data class ReplicatorAmazonMskCluster(val mskClusterArn: String)

Details of an Amazon MSK cluster.

Link copied to clipboard
data class ReplicatorConsumerGroupReplication(val consumerGroupsToExclude: List<String>? = null, val consumerGroupsToReplicate: List<String>, val detectAndCopyNewConsumerGroups: Boolean? = null, val synchroniseConsumerGroupOffsets: Boolean? = null)

Configuration relating to consumer group replication.

Link copied to clipboard

Details of a Kafka cluster for replication.

Link copied to clipboard
data class ReplicatorKafkaClusterClientVpcConfig(val securityGroupIds: List<String>? = null, val subnetIds: List<String>)

Details of an Amazon VPC which has network connectivity to the Kafka cluster.

Link copied to clipboard
data class ReplicatorReplicationInfo(val consumerGroupReplication: ReplicatorConsumerGroupReplication, val sourceKafkaClusterArn: String, val targetCompressionType: ReplicatorReplicationInfoTargetCompressionType, val targetKafkaClusterArn: String, val topicReplication: ReplicatorTopicReplication)

Specifies configuration for replication between a source and target Kafka cluster.

Link copied to clipboard

Configuration for specifying the position in the topics to start replicating from.

Configuration for specifying replicated topic names should be the same as their corresponding upstream topics or prefixed with source cluster alias.

Link copied to clipboard
data class ReplicatorTopicReplication(val copyAccessControlListsForTopics: Boolean? = null, val copyTopicConfigurations: Boolean? = null, val detectAndCopyNewTopics: Boolean? = null, val startingPosition: ReplicatorReplicationStartingPosition? = null, val topicNameConfiguration: ReplicatorReplicationTopicNameConfiguration? = null, val topicsToExclude: List<String>? = null, val topicsToReplicate: List<String>)
Link copied to clipboard
data class ServerlessClusterIam(val enabled: Boolean)
Link copied to clipboard
Link copied to clipboard
data class ServerlessClusterVpcConfig(val securityGroups: List<String>? = null, val subnetIds: List<String>)