R/kafka_interfaces.R

In paws.analytics: 'Amazon Web Services' Analytics Services

# This file is generated by make.paws. Please do not edit here.
#' @importFrom paws.common populate
#' @include kafka_service.R
NULL

.kafka$batch_associate_scram_secret_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), SecretArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "secretArnList", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$batch_associate_scram_secret_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), UnprocessedScramSecrets = structure(list(structure(list(ErrorCode = structure(logical(0), tags = list(locationName = "errorCode", type = "string")), ErrorMessage = structure(logical(0), tags = list(locationName = "errorMessage", type = "string")), SecretArn = structure(logical(0), tags = list(locationName = "secretArn", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "unprocessedScramSecrets", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_cluster_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(BrokerNodeGroupInfo = structure(list(BrokerAZDistribution = structure(logical(0), tags = list(locationName = "brokerAZDistribution", type = "string")), ClientSubnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "clientSubnets", type = "list")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), SecurityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroups", type = "list")), StorageInfo = structure(list(EbsStorageInfo = structure(list(ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSize = structure(logical(0), tags = list(locationName = "volumeSize", type = "integer"))), tags = list(locationName = "ebsStorageInfo", type = "structure"))), tags = list(locationName = "storageInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), ZoneIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "zoneIds", type = "list"))), tags = list(locationName = "brokerNodeGroupInfo", type = "structure")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), ClusterName = structure(logical(0), tags = list(locationName = "clusterName", type = "string")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_cluster_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterName = structure(logical(0), tags = list(locationName = "clusterName", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_cluster_v2_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterName = structure(logical(0), tags = list(locationName = "clusterName", type = "string")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map")), Provisioned = structure(list(BrokerNodeGroupInfo = structure(list(BrokerAZDistribution = structure(logical(0), tags = list(locationName = "brokerAZDistribution", type = "string")), ClientSubnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "clientSubnets", type = "list")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), SecurityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroups", type = "list")), StorageInfo = structure(list(EbsStorageInfo = structure(list(ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSize = structure(logical(0), tags = list(locationName = "volumeSize", type = "integer"))), tags = list(locationName = "ebsStorageInfo", type = "structure"))), tags = list(locationName = "storageInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), ZoneIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "zoneIds", type = "list"))), tags = list(locationName = "brokerNodeGroupInfo", type = "structure")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string"))), tags = list(locationName = "provisioned", type = "structure")), Serverless = structure(list(VpcConfigs = structure(list(structure(list(SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "subnetIds", type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroupIds", type = "list"))), tags = list(type = "structure"))), tags = list(locationName = "vpcConfigs", type = "list")), ClientAuthentication = structure(list(Sasl = structure(list(Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "serverless", type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_cluster_v2_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterName = structure(logical(0), tags = list(locationName = "clusterName", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string")), ClusterType = structure(logical(0), tags = list(locationName = "clusterType", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Description = structure(logical(0), tags = list(locationName = "description", type = "string")), KafkaVersions = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "kafkaVersions", type = "list")), Name = structure(logical(0), tags = list(locationName = "name", type = "string")), ServerProperties = structure(logical(0), tags = list(locationName = "serverProperties", type = "blob"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), LatestRevision = structure(list(CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Description = structure(logical(0), tags = list(locationName = "description", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "latestRevision", type = "structure")), Name = structure(logical(0), tags = list(locationName = "name", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_replicator_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Description = structure(logical(0), tags = list(locationName = "description", type = "string")), KafkaClusters = structure(list(structure(list(AmazonMskCluster = structure(list(MskClusterArn = structure(logical(0), tags = list(locationName = "mskClusterArn", type = "string"))), tags = list(locationName = "amazonMskCluster", type = "structure")), VpcConfig = structure(list(SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroupIds", type = "list")), SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "subnetIds", type = "list"))), tags = list(locationName = "vpcConfig", type = "structure"))), tags = list(type = "structure"))), tags = list(locationName = "kafkaClusters", type = "list")), ReplicationInfoList = structure(list(structure(list(ConsumerGroupReplication = structure(list(ConsumerGroupsToExclude = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "consumerGroupsToExclude", type = "list")), ConsumerGroupsToReplicate = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "consumerGroupsToReplicate", type = "list")), DetectAndCopyNewConsumerGroups = structure(logical(0), tags = list(locationName = "detectAndCopyNewConsumerGroups", type = "boolean")), SynchroniseConsumerGroupOffsets = structure(logical(0), tags = list(locationName = "synchroniseConsumerGroupOffsets", type = "boolean"))), tags = list(locationName = "consumerGroupReplication", type = "structure")), SourceKafkaClusterArn = structure(logical(0), tags = list(locationName = "sourceKafkaClusterArn", type = "string")), TargetCompressionType = structure(logical(0), tags = list(locationName = "targetCompressionType", type = "string")), TargetKafkaClusterArn = structure(logical(0), tags = list(locationName = "targetKafkaClusterArn", type = "string")), TopicReplication = structure(list(CopyAccessControlListsForTopics = structure(logical(0), tags = list(locationName = "copyAccessControlListsForTopics", type = "boolean")), CopyTopicConfigurations = structure(logical(0), tags = list(locationName = "copyTopicConfigurations", type = "boolean")), DetectAndCopyNewTopics = structure(logical(0), tags = list(locationName = "detectAndCopyNewTopics", type = "boolean")), StartingPosition = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "startingPosition", type = "structure")), TopicsToExclude = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "topicsToExclude", type = "list")), TopicsToReplicate = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "topicsToReplicate", type = "list"))), tags = list(locationName = "topicReplication", type = "structure"))), tags = list(type = "structure"))), tags = list(locationName = "replicationInfoList", type = "list")), ReplicatorName = structure(logical(0), tags = list(locationName = "replicatorName", type = "string")), ServiceExecutionRoleArn = structure(logical(0), tags = list(locationName = "serviceExecutionRoleArn", type = "string")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_replicator_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ReplicatorArn = structure(logical(0), tags = list(locationName = "replicatorArn", type = "string")), ReplicatorName = structure(logical(0), tags = list(locationName = "replicatorName", type = "string")), ReplicatorState = structure(logical(0), tags = list(locationName = "replicatorState", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_vpc_connection_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(TargetClusterArn = structure(logical(0), tags = list(locationName = "targetClusterArn", type = "string")), Authentication = structure(logical(0), tags = list(locationName = "authentication", type = "string")), VpcId = structure(logical(0), tags = list(locationName = "vpcId", type = "string")), ClientSubnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "clientSubnets", type = "list")), SecurityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroups", type = "list")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$create_vpc_connection_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string")), Authentication = structure(logical(0), tags = list(locationName = "authentication", type = "string")), VpcId = structure(logical(0), tags = list(locationName = "vpcId", type = "string")), ClientSubnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "clientSubnets", type = "list")), SecurityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroups", type = "list")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_cluster_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), CurrentVersion = structure(logical(0), tags = list(location = "querystring", locationName = "currentVersion", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_cluster_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_cluster_policy_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_cluster_policy_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(location = "uri", locationName = "arn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_replicator_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(CurrentVersion = structure(logical(0), tags = list(location = "querystring", locationName = "currentVersion", type = "string")), ReplicatorArn = structure(logical(0), tags = list(location = "uri", locationName = "replicatorArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_replicator_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ReplicatorArn = structure(logical(0), tags = list(locationName = "replicatorArn", type = "string")), ReplicatorState = structure(logical(0), tags = list(locationName = "replicatorState", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_vpc_connection_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(location = "uri", locationName = "arn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$delete_vpc_connection_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_cluster_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_cluster_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterInfo = structure(list(ActiveOperationArn = structure(logical(0), tags = list(locationName = "activeOperationArn", type = "string")), BrokerNodeGroupInfo = structure(list(BrokerAZDistribution = structure(logical(0), tags = list(locationName = "brokerAZDistribution", type = "string")), ClientSubnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "clientSubnets", type = "list")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), SecurityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroups", type = "list")), StorageInfo = structure(list(EbsStorageInfo = structure(list(ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSize = structure(logical(0), tags = list(locationName = "volumeSize", type = "integer"))), tags = list(locationName = "ebsStorageInfo", type = "structure"))), tags = list(locationName = "storageInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), ZoneIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "zoneIds", type = "list"))), tags = list(locationName = "brokerNodeGroupInfo", type = "structure")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterName = structure(logical(0), tags = list(locationName = "clusterName", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), CurrentBrokerSoftwareInfo = structure(list(ConfigurationArn = structure(logical(0), tags = list(locationName = "configurationArn", type = "string")), ConfigurationRevision = structure(logical(0), tags = list(locationName = "configurationRevision", type = "long")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string"))), tags = list(locationName = "currentBrokerSoftwareInfo", type = "structure")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), State = structure(logical(0), tags = list(locationName = "state", type = "string")), StateInfo = structure(list(Code = structure(logical(0), tags = list(locationName = "code", type = "string")), Message = structure(logical(0), tags = list(locationName = "message", type = "string"))), tags = list(locationName = "stateInfo", type = "structure")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map")), ZookeeperConnectString = structure(logical(0), tags = list(locationName = "zookeeperConnectString", type = "string")), ZookeeperConnectStringTls = structure(logical(0), tags = list(locationName = "zookeeperConnectStringTls", type = "string")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), CustomerActionStatus = structure(logical(0), tags = list(locationName = "customerActionStatus", type = "string"))), tags = list(locationName = "clusterInfo", type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_cluster_v2_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_cluster_v2_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterInfo = structure(list(ActiveOperationArn = structure(logical(0), tags = list(locationName = "activeOperationArn", type = "string")), ClusterType = structure(logical(0), tags = list(locationName = "clusterType", type = "string")), ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterName = structure(logical(0), tags = list(locationName = "clusterName", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string")), StateInfo = structure(list(Code = structure(logical(0), tags = list(locationName = "code", type = "string")), Message = structure(logical(0), tags = list(locationName = "message", type = "string"))), tags = list(locationName = "stateInfo", type = "structure")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map")), Provisioned = structure(list(BrokerNodeGroupInfo = structure(list(BrokerAZDistribution = structure(logical(0), tags = list(locationName = "brokerAZDistribution", type = "string")), ClientSubnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "clientSubnets", type = "list")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), SecurityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroups", type = "list")), StorageInfo = structure(list(EbsStorageInfo = structure(list(ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSize = structure(logical(0), tags = list(locationName = "volumeSize", type = "integer"))), tags = list(locationName = "ebsStorageInfo", type = "structure"))), tags = list(locationName = "storageInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), ZoneIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "zoneIds", type = "list"))), tags = list(locationName = "brokerNodeGroupInfo", type = "structure")), CurrentBrokerSoftwareInfo = structure(list(ConfigurationArn = structure(logical(0), tags = list(locationName = "configurationArn", type = "string")), ConfigurationRevision = structure(logical(0), tags = list(locationName = "configurationRevision", type = "long")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string"))), tags = list(locationName = "currentBrokerSoftwareInfo", type = "structure")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), ZookeeperConnectString = structure(logical(0), tags = list(locationName = "zookeeperConnectString", type = "string")), ZookeeperConnectStringTls = structure(logical(0), tags = list(locationName = "zookeeperConnectStringTls", type = "string")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), CustomerActionStatus = structure(logical(0), tags = list(locationName = "customerActionStatus", type = "string"))), tags = list(locationName = "provisioned", type = "structure")), Serverless = structure(list(VpcConfigs = structure(list(structure(list(SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "subnetIds", type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroupIds", type = "list"))), tags = list(type = "structure"))), tags = list(locationName = "vpcConfigs", type = "list")), ClientAuthentication = structure(list(Sasl = structure(list(Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "serverless", type = "structure"))), tags = list(locationName = "clusterInfo", type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_cluster_operation_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterOperationArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_cluster_operation_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterOperationInfo = structure(list(ClientRequestId = structure(logical(0), tags = list(locationName = "clientRequestId", type = "string")), ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), EndTime = structure(logical(0), tags = list(locationName = "endTime", type = "timestamp", timestampFormat = "iso8601")), ErrorInfo = structure(list(ErrorCode = structure(logical(0), tags = list(locationName = "errorCode", type = "string")), ErrorString = structure(logical(0), tags = list(locationName = "errorString", type = "string"))), tags = list(locationName = "errorInfo", type = "structure")), OperationArn = structure(logical(0), tags = list(locationName = "operationArn", type = "string")), OperationState = structure(logical(0), tags = list(locationName = "operationState", type = "string")), OperationSteps = structure(list(structure(list(StepInfo = structure(list(StepStatus = structure(logical(0), tags = list(locationName = "stepStatus", type = "string"))), tags = list(locationName = "stepInfo", type = "structure")), StepName = structure(logical(0), tags = list(locationName = "stepName", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "operationSteps", type = "list")), OperationType = structure(logical(0), tags = list(locationName = "operationType", type = "string")), SourceClusterInfo = structure(list(BrokerEBSVolumeInfo = structure(list(structure(list(KafkaBrokerNodeId = structure(logical(0), tags = list(locationName = "kafkaBrokerNodeId", type = "string")), ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSizeGB = structure(logical(0), tags = list(locationName = "volumeSizeGB", type = "integer"))), tags = list(type = "structure"))), tags = list(locationName = "brokerEBSVolumeInfo", type = "list")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), BrokerCountUpdateInfo = structure(list(CreatedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "createdBrokerIds", type = "list")), DeletedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "deletedBrokerIds", type = "list"))), tags = list(locationName = "brokerCountUpdateInfo", type = "structure"))), tags = list(locationName = "sourceClusterInfo", type = "structure")), TargetClusterInfo = structure(list(BrokerEBSVolumeInfo = structure(list(structure(list(KafkaBrokerNodeId = structure(logical(0), tags = list(locationName = "kafkaBrokerNodeId", type = "string")), ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSizeGB = structure(logical(0), tags = list(locationName = "volumeSizeGB", type = "integer"))), tags = list(type = "structure"))), tags = list(locationName = "brokerEBSVolumeInfo", type = "list")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), BrokerCountUpdateInfo = structure(list(CreatedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "createdBrokerIds", type = "list")), DeletedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "deletedBrokerIds", type = "list"))), tags = list(locationName = "brokerCountUpdateInfo", type = "structure"))), tags = list(locationName = "targetClusterInfo", type = "structure")), VpcConnectionInfo = structure(list(VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string")), Owner = structure(logical(0), tags = list(locationName = "owner", type = "string")), UserIdentity = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string")), PrincipalId = structure(logical(0), tags = list(locationName = "principalId", type = "string"))), tags = list(locationName = "userIdentity", type = "structure")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601"))), tags = list(locationName = "vpcConnectionInfo", type = "structure"))), tags = list(locationName = "clusterOperationInfo", type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_cluster_operation_v2_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterOperationArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_cluster_operation_v2_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterOperationInfo = structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterType = structure(logical(0), tags = list(locationName = "clusterType", type = "string")), StartTime = structure(logical(0), tags = list(locationName = "startTime", type = "timestamp", timestampFormat = "iso8601")), EndTime = structure(logical(0), tags = list(locationName = "endTime", type = "timestamp", timestampFormat = "iso8601")), ErrorInfo = structure(list(ErrorCode = structure(logical(0), tags = list(locationName = "errorCode", type = "string")), ErrorString = structure(logical(0), tags = list(locationName = "errorString", type = "string"))), tags = list(locationName = "errorInfo", type = "structure")), OperationArn = structure(logical(0), tags = list(locationName = "operationArn", type = "string")), OperationState = structure(logical(0), tags = list(locationName = "operationState", type = "string")), OperationType = structure(logical(0), tags = list(locationName = "operationType", type = "string")), Provisioned = structure(list(OperationSteps = structure(list(structure(list(StepInfo = structure(list(StepStatus = structure(logical(0), tags = list(locationName = "stepStatus", type = "string"))), tags = list(locationName = "stepInfo", type = "structure")), StepName = structure(logical(0), tags = list(locationName = "stepName", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "operationSteps", type = "list")), SourceClusterInfo = structure(list(BrokerEBSVolumeInfo = structure(list(structure(list(KafkaBrokerNodeId = structure(logical(0), tags = list(locationName = "kafkaBrokerNodeId", type = "string")), ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSizeGB = structure(logical(0), tags = list(locationName = "volumeSizeGB", type = "integer"))), tags = list(type = "structure"))), tags = list(locationName = "brokerEBSVolumeInfo", type = "list")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), BrokerCountUpdateInfo = structure(list(CreatedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "createdBrokerIds", type = "list")), DeletedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "deletedBrokerIds", type = "list"))), tags = list(locationName = "brokerCountUpdateInfo", type = "structure"))), tags = list(locationName = "sourceClusterInfo", type = "structure")), TargetClusterInfo = structure(list(BrokerEBSVolumeInfo = structure(list(structure(list(KafkaBrokerNodeId = structure(logical(0), tags = list(locationName = "kafkaBrokerNodeId", type = "string")), ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSizeGB = structure(logical(0), tags = list(locationName = "volumeSizeGB", type = "integer"))), tags = list(type = "structure"))), tags = list(locationName = "brokerEBSVolumeInfo", type = "list")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), BrokerCountUpdateInfo = structure(list(CreatedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "createdBrokerIds", type = "list")), DeletedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "deletedBrokerIds", type = "list"))), tags = list(locationName = "brokerCountUpdateInfo", type = "structure"))), tags = list(locationName = "targetClusterInfo", type = "structure")), VpcConnectionInfo = structure(list(VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string")), Owner = structure(logical(0), tags = list(locationName = "owner", type = "string")), UserIdentity = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string")), PrincipalId = structure(logical(0), tags = list(locationName = "principalId", type = "string"))), tags = list(locationName = "userIdentity", type = "structure")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601"))), tags = list(locationName = "vpcConnectionInfo", type = "structure"))), tags = list(locationName = "provisioned", type = "structure")), Serverless = structure(list(VpcConnectionInfo = structure(list(CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Owner = structure(logical(0), tags = list(locationName = "owner", type = "string")), UserIdentity = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string")), PrincipalId = structure(logical(0), tags = list(locationName = "principalId", type = "string"))), tags = list(locationName = "userIdentity", type = "structure")), VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string"))), tags = list(locationName = "vpcConnectionInfo", type = "structure"))), tags = list(locationName = "serverless", type = "structure"))), tags = list(locationName = "clusterOperationInfo", type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(location = "uri", locationName = "arn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Description = structure(logical(0), tags = list(locationName = "description", type = "string")), KafkaVersions = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "kafkaVersions", type = "list")), LatestRevision = structure(list(CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Description = structure(logical(0), tags = list(locationName = "description", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "latestRevision", type = "structure")), Name = structure(logical(0), tags = list(locationName = "name", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_configuration_revision_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(location = "uri", locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(location = "uri", locationName = "revision", type = "long"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_configuration_revision_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Description = structure(logical(0), tags = list(locationName = "description", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long")), ServerProperties = structure(logical(0), tags = list(locationName = "serverProperties", type = "blob"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_replicator_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ReplicatorArn = structure(logical(0), tags = list(location = "uri", locationName = "replicatorArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_replicator_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), IsReplicatorReference = structure(logical(0), tags = list(locationName = "isReplicatorReference", type = "boolean")), KafkaClusters = structure(list(structure(list(AmazonMskCluster = structure(list(MskClusterArn = structure(logical(0), tags = list(locationName = "mskClusterArn", type = "string"))), tags = list(locationName = "amazonMskCluster", type = "structure")), KafkaClusterAlias = structure(logical(0), tags = list(locationName = "kafkaClusterAlias", type = "string")), VpcConfig = structure(list(SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroupIds", type = "list")), SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "subnetIds", type = "list"))), tags = list(locationName = "vpcConfig", type = "structure"))), tags = list(type = "structure"))), tags = list(locationName = "kafkaClusters", type = "list")), ReplicationInfoList = structure(list(structure(list(ConsumerGroupReplication = structure(list(ConsumerGroupsToExclude = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "consumerGroupsToExclude", type = "list")), ConsumerGroupsToReplicate = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "consumerGroupsToReplicate", type = "list")), DetectAndCopyNewConsumerGroups = structure(logical(0), tags = list(locationName = "detectAndCopyNewConsumerGroups", type = "boolean")), SynchroniseConsumerGroupOffsets = structure(logical(0), tags = list(locationName = "synchroniseConsumerGroupOffsets", type = "boolean"))), tags = list(locationName = "consumerGroupReplication", type = "structure")), SourceKafkaClusterAlias = structure(logical(0), tags = list(locationName = "sourceKafkaClusterAlias", type = "string")), TargetCompressionType = structure(logical(0), tags = list(locationName = "targetCompressionType", type = "string")), TargetKafkaClusterAlias = structure(logical(0), tags = list(locationName = "targetKafkaClusterAlias", type = "string")), TopicReplication = structure(list(CopyAccessControlListsForTopics = structure(logical(0), tags = list(locationName = "copyAccessControlListsForTopics", type = "boolean")), CopyTopicConfigurations = structure(logical(0), tags = list(locationName = "copyTopicConfigurations", type = "boolean")), DetectAndCopyNewTopics = structure(logical(0), tags = list(locationName = "detectAndCopyNewTopics", type = "boolean")), StartingPosition = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "startingPosition", type = "structure")), TopicsToExclude = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "topicsToExclude", type = "list")), TopicsToReplicate = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "topicsToReplicate", type = "list"))), tags = list(locationName = "topicReplication", type = "structure"))), tags = list(type = "structure"))), tags = list(locationName = "replicationInfoList", type = "list")), ReplicatorArn = structure(logical(0), tags = list(locationName = "replicatorArn", type = "string")), ReplicatorDescription = structure(logical(0), tags = list(locationName = "replicatorDescription", type = "string")), ReplicatorName = structure(logical(0), tags = list(locationName = "replicatorName", type = "string")), ReplicatorResourceArn = structure(logical(0), tags = list(locationName = "replicatorResourceArn", type = "string")), ReplicatorState = structure(logical(0), tags = list(locationName = "replicatorState", type = "string")), ServiceExecutionRoleArn = structure(logical(0), tags = list(locationName = "serviceExecutionRoleArn", type = "string")), StateInfo = structure(list(Code = structure(logical(0), tags = list(locationName = "code", type = "string")), Message = structure(logical(0), tags = list(locationName = "message", type = "string"))), tags = list(locationName = "stateInfo", type = "structure")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_vpc_connection_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(location = "uri", locationName = "arn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$describe_vpc_connection_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string")), TargetClusterArn = structure(logical(0), tags = list(locationName = "targetClusterArn", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string")), Authentication = structure(logical(0), tags = list(locationName = "authentication", type = "string")), VpcId = structure(logical(0), tags = list(locationName = "vpcId", type = "string")), Subnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "subnets", type = "list")), SecurityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroups", type = "list")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$batch_disassociate_scram_secret_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), SecretArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "secretArnList", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$batch_disassociate_scram_secret_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), UnprocessedScramSecrets = structure(list(structure(list(ErrorCode = structure(logical(0), tags = list(locationName = "errorCode", type = "string")), ErrorMessage = structure(logical(0), tags = list(locationName = "errorMessage", type = "string")), SecretArn = structure(logical(0), tags = list(locationName = "secretArn", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "unprocessedScramSecrets", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$get_bootstrap_brokers_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$get_bootstrap_brokers_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(BootstrapBrokerString = structure(logical(0), tags = list(locationName = "bootstrapBrokerString", type = "string")), BootstrapBrokerStringTls = structure(logical(0), tags = list(locationName = "bootstrapBrokerStringTls", type = "string")), BootstrapBrokerStringSaslScram = structure(logical(0), tags = list(locationName = "bootstrapBrokerStringSaslScram", type = "string")), BootstrapBrokerStringSaslIam = structure(logical(0), tags = list(locationName = "bootstrapBrokerStringSaslIam", type = "string")), BootstrapBrokerStringPublicTls = structure(logical(0), tags = list(locationName = "bootstrapBrokerStringPublicTls", type = "string")), BootstrapBrokerStringPublicSaslScram = structure(logical(0), tags = list(locationName = "bootstrapBrokerStringPublicSaslScram", type = "string")), BootstrapBrokerStringPublicSaslIam = structure(logical(0), tags = list(locationName = "bootstrapBrokerStringPublicSaslIam", type = "string")), BootstrapBrokerStringVpcConnectivityTls = structure(logical(0), tags = list(locationName = "bootstrapBrokerStringVpcConnectivityTls", type = "string")), BootstrapBrokerStringVpcConnectivitySaslScram = structure(logical(0), tags = list(locationName = "bootstrapBrokerStringVpcConnectivitySaslScram", type = "string")), BootstrapBrokerStringVpcConnectivitySaslIam = structure(logical(0), tags = list(locationName = "bootstrapBrokerStringVpcConnectivitySaslIam", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$get_compatible_kafka_versions_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "querystring", locationName = "clusterArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$get_compatible_kafka_versions_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(CompatibleKafkaVersions = structure(list(structure(list(SourceVersion = structure(logical(0), tags = list(locationName = "sourceVersion", type = "string")), TargetVersions = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "targetVersions", type = "list"))), tags = list(type = "structure"))), tags = list(locationName = "compatibleKafkaVersions", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$get_cluster_policy_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$get_cluster_policy_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), Policy = structure(logical(0), tags = list(locationName = "policy", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_cluster_operations_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_cluster_operations_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterOperationInfoList = structure(list(structure(list(ClientRequestId = structure(logical(0), tags = list(locationName = "clientRequestId", type = "string")), ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), EndTime = structure(logical(0), tags = list(locationName = "endTime", type = "timestamp", timestampFormat = "iso8601")), ErrorInfo = structure(list(ErrorCode = structure(logical(0), tags = list(locationName = "errorCode", type = "string")), ErrorString = structure(logical(0), tags = list(locationName = "errorString", type = "string"))), tags = list(locationName = "errorInfo", type = "structure")), OperationArn = structure(logical(0), tags = list(locationName = "operationArn", type = "string")), OperationState = structure(logical(0), tags = list(locationName = "operationState", type = "string")), OperationSteps = structure(list(structure(list(StepInfo = structure(list(StepStatus = structure(logical(0), tags = list(locationName = "stepStatus", type = "string"))), tags = list(locationName = "stepInfo", type = "structure")), StepName = structure(logical(0), tags = list(locationName = "stepName", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "operationSteps", type = "list")), OperationType = structure(logical(0), tags = list(locationName = "operationType", type = "string")), SourceClusterInfo = structure(list(BrokerEBSVolumeInfo = structure(list(structure(list(KafkaBrokerNodeId = structure(logical(0), tags = list(locationName = "kafkaBrokerNodeId", type = "string")), ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSizeGB = structure(logical(0), tags = list(locationName = "volumeSizeGB", type = "integer"))), tags = list(type = "structure"))), tags = list(locationName = "brokerEBSVolumeInfo", type = "list")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), BrokerCountUpdateInfo = structure(list(CreatedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "createdBrokerIds", type = "list")), DeletedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "deletedBrokerIds", type = "list"))), tags = list(locationName = "brokerCountUpdateInfo", type = "structure"))), tags = list(locationName = "sourceClusterInfo", type = "structure")), TargetClusterInfo = structure(list(BrokerEBSVolumeInfo = structure(list(structure(list(KafkaBrokerNodeId = structure(logical(0), tags = list(locationName = "kafkaBrokerNodeId", type = "string")), ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSizeGB = structure(logical(0), tags = list(locationName = "volumeSizeGB", type = "integer"))), tags = list(type = "structure"))), tags = list(locationName = "brokerEBSVolumeInfo", type = "list")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), BrokerCountUpdateInfo = structure(list(CreatedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "createdBrokerIds", type = "list")), DeletedBrokerIds = structure(list(structure(logical(0), tags = list(type = "double"))), tags = list(locationName = "deletedBrokerIds", type = "list"))), tags = list(locationName = "brokerCountUpdateInfo", type = "structure"))), tags = list(locationName = "targetClusterInfo", type = "structure")), VpcConnectionInfo = structure(list(VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string")), Owner = structure(logical(0), tags = list(locationName = "owner", type = "string")), UserIdentity = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string")), PrincipalId = structure(logical(0), tags = list(locationName = "principalId", type = "string"))), tags = list(locationName = "userIdentity", type = "structure")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601"))), tags = list(locationName = "vpcConnectionInfo", type = "structure"))), tags = list(type = "structure"))), tags = list(locationName = "clusterOperationInfoList", type = "list")), NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_cluster_operations_v2_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_cluster_operations_v2_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterOperationInfoList = structure(list(structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterType = structure(logical(0), tags = list(locationName = "clusterType", type = "string")), StartTime = structure(logical(0), tags = list(locationName = "startTime", type = "timestamp", timestampFormat = "iso8601")), EndTime = structure(logical(0), tags = list(locationName = "endTime", type = "timestamp", timestampFormat = "iso8601")), OperationArn = structure(logical(0), tags = list(locationName = "operationArn", type = "string")), OperationState = structure(logical(0), tags = list(locationName = "operationState", type = "string")), OperationType = structure(logical(0), tags = list(locationName = "operationType", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "clusterOperationInfoList", type = "list")), NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_clusters_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterNameFilter = structure(logical(0), tags = list(location = "querystring", locationName = "clusterNameFilter", type = "string")), MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_clusters_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterInfoList = structure(list(structure(list(ActiveOperationArn = structure(logical(0), tags = list(locationName = "activeOperationArn", type = "string")), BrokerNodeGroupInfo = structure(list(BrokerAZDistribution = structure(logical(0), tags = list(locationName = "brokerAZDistribution", type = "string")), ClientSubnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "clientSubnets", type = "list")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), SecurityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroups", type = "list")), StorageInfo = structure(list(EbsStorageInfo = structure(list(ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSize = structure(logical(0), tags = list(locationName = "volumeSize", type = "integer"))), tags = list(locationName = "ebsStorageInfo", type = "structure"))), tags = list(locationName = "storageInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), ZoneIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "zoneIds", type = "list"))), tags = list(locationName = "brokerNodeGroupInfo", type = "structure")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterName = structure(logical(0), tags = list(locationName = "clusterName", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), CurrentBrokerSoftwareInfo = structure(list(ConfigurationArn = structure(logical(0), tags = list(locationName = "configurationArn", type = "string")), ConfigurationRevision = structure(logical(0), tags = list(locationName = "configurationRevision", type = "long")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string"))), tags = list(locationName = "currentBrokerSoftwareInfo", type = "structure")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), State = structure(logical(0), tags = list(locationName = "state", type = "string")), StateInfo = structure(list(Code = structure(logical(0), tags = list(locationName = "code", type = "string")), Message = structure(logical(0), tags = list(locationName = "message", type = "string"))), tags = list(locationName = "stateInfo", type = "structure")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map")), ZookeeperConnectString = structure(logical(0), tags = list(locationName = "zookeeperConnectString", type = "string")), ZookeeperConnectStringTls = structure(logical(0), tags = list(locationName = "zookeeperConnectStringTls", type = "string")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), CustomerActionStatus = structure(logical(0), tags = list(locationName = "customerActionStatus", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "clusterInfoList", type = "list")), NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_clusters_v2_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterNameFilter = structure(logical(0), tags = list(location = "querystring", locationName = "clusterNameFilter", type = "string")), ClusterTypeFilter = structure(logical(0), tags = list(location = "querystring", locationName = "clusterTypeFilter", type = "string")), MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_clusters_v2_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterInfoList = structure(list(structure(list(ActiveOperationArn = structure(logical(0), tags = list(locationName = "activeOperationArn", type = "string")), ClusterType = structure(logical(0), tags = list(locationName = "clusterType", type = "string")), ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterName = structure(logical(0), tags = list(locationName = "clusterName", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string")), StateInfo = structure(list(Code = structure(logical(0), tags = list(locationName = "code", type = "string")), Message = structure(logical(0), tags = list(locationName = "message", type = "string"))), tags = list(locationName = "stateInfo", type = "structure")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map")), Provisioned = structure(list(BrokerNodeGroupInfo = structure(list(BrokerAZDistribution = structure(logical(0), tags = list(locationName = "brokerAZDistribution", type = "string")), ClientSubnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "clientSubnets", type = "list")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), SecurityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroups", type = "list")), StorageInfo = structure(list(EbsStorageInfo = structure(list(ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSize = structure(logical(0), tags = list(locationName = "volumeSize", type = "integer"))), tags = list(locationName = "ebsStorageInfo", type = "structure"))), tags = list(locationName = "storageInfo", type = "structure")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), ZoneIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "zoneIds", type = "list"))), tags = list(locationName = "brokerNodeGroupInfo", type = "structure")), CurrentBrokerSoftwareInfo = structure(list(ConfigurationArn = structure(logical(0), tags = list(locationName = "configurationArn", type = "string")), ConfigurationRevision = structure(logical(0), tags = list(locationName = "configurationRevision", type = "long")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string"))), tags = list(locationName = "currentBrokerSoftwareInfo", type = "structure")), ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure")), NumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "numberOfBrokerNodes", type = "integer")), ZookeeperConnectString = structure(logical(0), tags = list(locationName = "zookeeperConnectString", type = "string")), ZookeeperConnectStringTls = structure(logical(0), tags = list(locationName = "zookeeperConnectStringTls", type = "string")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), CustomerActionStatus = structure(logical(0), tags = list(locationName = "customerActionStatus", type = "string"))), tags = list(locationName = "provisioned", type = "structure")), Serverless = structure(list(VpcConfigs = structure(list(structure(list(SubnetIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "subnetIds", type = "list")), SecurityGroupIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "securityGroupIds", type = "list"))), tags = list(type = "structure"))), tags = list(locationName = "vpcConfigs", type = "list")), ClientAuthentication = structure(list(Sasl = structure(list(Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "serverless", type = "structure"))), tags = list(type = "structure"))), tags = list(locationName = "clusterInfoList", type = "list")), NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_configuration_revisions_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(location = "uri", locationName = "arn", type = "string")), MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_configuration_revisions_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string")), Revisions = structure(list(structure(list(CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Description = structure(logical(0), tags = list(locationName = "description", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(type = "structure"))), tags = list(locationName = "revisions", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_configurations_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_configurations_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Configurations = structure(list(structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Description = structure(logical(0), tags = list(locationName = "description", type = "string")), KafkaVersions = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "kafkaVersions", type = "list")), LatestRevision = structure(list(CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Description = structure(logical(0), tags = list(locationName = "description", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "latestRevision", type = "structure")), Name = structure(logical(0), tags = list(locationName = "name", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "configurations", type = "list")), NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_kafka_versions_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_kafka_versions_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(KafkaVersions = structure(list(structure(list(Version = structure(logical(0), tags = list(locationName = "version", type = "string")), Status = structure(logical(0), tags = list(locationName = "status", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "kafkaVersions", type = "list")), NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_nodes_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_nodes_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string")), NodeInfoList = structure(list(structure(list(AddedToClusterTime = structure(logical(0), tags = list(locationName = "addedToClusterTime", type = "string")), BrokerNodeInfo = structure(list(AttachedENIId = structure(logical(0), tags = list(locationName = "attachedENIId", type = "string")), BrokerId = structure(logical(0), tags = list(locationName = "brokerId", type = "double")), ClientSubnet = structure(logical(0), tags = list(locationName = "clientSubnet", type = "string")), ClientVpcIpAddress = structure(logical(0), tags = list(locationName = "clientVpcIpAddress", type = "string")), CurrentBrokerSoftwareInfo = structure(list(ConfigurationArn = structure(logical(0), tags = list(locationName = "configurationArn", type = "string")), ConfigurationRevision = structure(logical(0), tags = list(locationName = "configurationRevision", type = "long")), KafkaVersion = structure(logical(0), tags = list(locationName = "kafkaVersion", type = "string"))), tags = list(locationName = "currentBrokerSoftwareInfo", type = "structure")), Endpoints = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "endpoints", type = "list"))), tags = list(locationName = "brokerNodeInfo", type = "structure")), ControllerNodeInfo = structure(list(Endpoints = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "endpoints", type = "list"))), tags = list(locationName = "controllerNodeInfo", type = "structure")), InstanceType = structure(logical(0), tags = list(locationName = "instanceType", type = "string")), NodeARN = structure(logical(0), tags = list(locationName = "nodeARN", type = "string")), NodeType = structure(logical(0), tags = list(locationName = "nodeType", type = "string")), ZookeeperNodeInfo = structure(list(AttachedENIId = structure(logical(0), tags = list(locationName = "attachedENIId", type = "string")), ClientVpcIpAddress = structure(logical(0), tags = list(locationName = "clientVpcIpAddress", type = "string")), Endpoints = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "endpoints", type = "list")), ZookeeperId = structure(logical(0), tags = list(locationName = "zookeeperId", type = "double")), ZookeeperVersion = structure(logical(0), tags = list(locationName = "zookeeperVersion", type = "string"))), tags = list(locationName = "zookeeperNodeInfo", type = "structure"))), tags = list(type = "structure"))), tags = list(locationName = "nodeInfoList", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_replicators_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string")), ReplicatorNameFilter = structure(logical(0), tags = list(location = "querystring", locationName = "replicatorNameFilter", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_replicators_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string")), Replicators = structure(list(structure(list(CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), IsReplicatorReference = structure(logical(0), tags = list(locationName = "isReplicatorReference", type = "boolean")), KafkaClustersSummary = structure(list(structure(list(AmazonMskCluster = structure(list(MskClusterArn = structure(logical(0), tags = list(locationName = "mskClusterArn", type = "string"))), tags = list(locationName = "amazonMskCluster", type = "structure")), KafkaClusterAlias = structure(logical(0), tags = list(locationName = "kafkaClusterAlias", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "kafkaClustersSummary", type = "list")), ReplicationInfoSummaryList = structure(list(structure(list(SourceKafkaClusterAlias = structure(logical(0), tags = list(locationName = "sourceKafkaClusterAlias", type = "string")), TargetKafkaClusterAlias = structure(logical(0), tags = list(locationName = "targetKafkaClusterAlias", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "replicationInfoSummaryList", type = "list")), ReplicatorArn = structure(logical(0), tags = list(locationName = "replicatorArn", type = "string")), ReplicatorName = structure(logical(0), tags = list(locationName = "replicatorName", type = "string")), ReplicatorResourceArn = structure(logical(0), tags = list(locationName = "replicatorResourceArn", type = "string")), ReplicatorState = structure(logical(0), tags = list(locationName = "replicatorState", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "replicators", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_scram_secrets_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_scram_secrets_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string")), SecretArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "secretArnList", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_tags_for_resource_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ResourceArn = structure(logical(0), tags = list(location = "uri", locationName = "resourceArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_tags_for_resource_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_client_vpc_connections_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_client_vpc_connections_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClientVpcConnections = structure(list(structure(list(Authentication = structure(logical(0), tags = list(locationName = "authentication", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), State = structure(logical(0), tags = list(locationName = "state", type = "string")), VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string")), Owner = structure(logical(0), tags = list(locationName = "owner", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "clientVpcConnections", type = "list")), NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_vpc_connections_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(MaxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), NextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$list_vpc_connections_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(VpcConnections = structure(list(structure(list(VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string")), TargetClusterArn = structure(logical(0), tags = list(locationName = "targetClusterArn", type = "string")), CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Authentication = structure(logical(0), tags = list(locationName = "authentication", type = "string")), VpcId = structure(logical(0), tags = list(locationName = "vpcId", type = "string")), State = structure(logical(0), tags = list(locationName = "state", type = "string"))), tags = list(type = "structure"))), tags = list(locationName = "vpcConnections", type = "list")), NextToken = structure(logical(0), tags = list(locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$reject_client_vpc_connection_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), VpcConnectionArn = structure(logical(0), tags = list(locationName = "vpcConnectionArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$reject_client_vpc_connection_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$put_cluster_policy_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), Policy = structure(logical(0), tags = list(locationName = "policy", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$put_cluster_policy_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$reboot_broker_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(BrokerIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "brokerIds", type = "list")), ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$reboot_broker_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$tag_resource_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ResourceArn = structure(logical(0), tags = list(location = "uri", locationName = "resourceArn", type = "string")), Tags = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "tags", type = "map"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$tag_resource_output <- function(...) {
  list()
}

.kafka$untag_resource_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ResourceArn = structure(logical(0), tags = list(location = "uri", locationName = "resourceArn", type = "string")), TagKeys = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(location = "querystring", locationName = "tagKeys", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$untag_resource_output <- function(...) {
  list()
}

.kafka$update_broker_count_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), TargetNumberOfBrokerNodes = structure(logical(0), tags = list(locationName = "targetNumberOfBrokerNodes", type = "integer"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_broker_count_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_broker_type_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), TargetInstanceType = structure(logical(0), tags = list(locationName = "targetInstanceType", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_broker_type_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_broker_storage_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), TargetBrokerEBSVolumeInfo = structure(list(structure(list(KafkaBrokerNodeId = structure(logical(0), tags = list(locationName = "kafkaBrokerNodeId", type = "string")), ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), VolumeSizeGB = structure(logical(0), tags = list(locationName = "volumeSizeGB", type = "integer"))), tags = list(type = "structure"))), tags = list(locationName = "targetBrokerEBSVolumeInfo", type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_broker_storage_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(location = "uri", locationName = "arn", type = "string")), Description = structure(logical(0), tags = list(locationName = "description", type = "string")), ServerProperties = structure(logical(0), tags = list(locationName = "serverProperties", type = "blob"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), LatestRevision = structure(list(CreationTime = structure(logical(0), tags = list(locationName = "creationTime", type = "timestamp", timestampFormat = "iso8601")), Description = structure(logical(0), tags = list(locationName = "description", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "latestRevision", type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_connectivity_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), ConnectivityInfo = structure(list(PublicAccess = structure(list(Type = structure(logical(0), tags = list(locationName = "type", type = "string"))), tags = list(locationName = "publicAccess", type = "structure")), VpcConnectivity = structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure"))), tags = list(locationName = "vpcConnectivity", type = "structure"))), tags = list(locationName = "connectivityInfo", type = "structure")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_connectivity_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_cluster_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_cluster_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_cluster_kafka_version_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), ConfigurationInfo = structure(list(Arn = structure(logical(0), tags = list(locationName = "arn", type = "string")), Revision = structure(logical(0), tags = list(locationName = "revision", type = "long"))), tags = list(locationName = "configurationInfo", type = "structure")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), TargetKafkaVersion = structure(logical(0), tags = list(locationName = "targetKafkaVersion", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_cluster_kafka_version_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_monitoring_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), EnhancedMonitoring = structure(logical(0), tags = list(locationName = "enhancedMonitoring", type = "string")), OpenMonitoring = structure(list(Prometheus = structure(list(JmxExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "jmxExporter", type = "structure")), NodeExporter = structure(list(EnabledInBroker = structure(logical(0), tags = list(locationName = "enabledInBroker", type = "boolean"))), tags = list(locationName = "nodeExporter", type = "structure"))), tags = list(locationName = "prometheus", type = "structure"))), tags = list(locationName = "openMonitoring", type = "structure")), LoggingInfo = structure(list(BrokerLogs = structure(list(CloudWatchLogs = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), LogGroup = structure(logical(0), tags = list(locationName = "logGroup", type = "string"))), tags = list(locationName = "cloudWatchLogs", type = "structure")), Firehose = structure(list(DeliveryStream = structure(logical(0), tags = list(locationName = "deliveryStream", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "firehose", type = "structure")), S3 = structure(list(Bucket = structure(logical(0), tags = list(locationName = "bucket", type = "string")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), Prefix = structure(logical(0), tags = list(locationName = "prefix", type = "string"))), tags = list(locationName = "s3", type = "structure"))), tags = list(locationName = "brokerLogs", type = "structure"))), tags = list(locationName = "loggingInfo", type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_monitoring_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_replication_info_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ConsumerGroupReplication = structure(list(ConsumerGroupsToExclude = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "consumerGroupsToExclude", type = "list")), ConsumerGroupsToReplicate = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "consumerGroupsToReplicate", type = "list")), DetectAndCopyNewConsumerGroups = structure(logical(0), tags = list(locationName = "detectAndCopyNewConsumerGroups", type = "boolean")), SynchroniseConsumerGroupOffsets = structure(logical(0), tags = list(locationName = "synchroniseConsumerGroupOffsets", type = "boolean"))), tags = list(locationName = "consumerGroupReplication", type = "structure")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), ReplicatorArn = structure(logical(0), tags = list(location = "uri", locationName = "replicatorArn", type = "string")), SourceKafkaClusterArn = structure(logical(0), tags = list(locationName = "sourceKafkaClusterArn", type = "string")), TargetKafkaClusterArn = structure(logical(0), tags = list(locationName = "targetKafkaClusterArn", type = "string")), TopicReplication = structure(list(CopyAccessControlListsForTopics = structure(logical(0), tags = list(locationName = "copyAccessControlListsForTopics", type = "boolean")), CopyTopicConfigurations = structure(logical(0), tags = list(locationName = "copyTopicConfigurations", type = "boolean")), DetectAndCopyNewTopics = structure(logical(0), tags = list(locationName = "detectAndCopyNewTopics", type = "boolean")), TopicsToExclude = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "topicsToExclude", type = "list")), TopicsToReplicate = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "topicsToReplicate", type = "list"))), tags = list(locationName = "topicReplication", type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_replication_info_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ReplicatorArn = structure(logical(0), tags = list(locationName = "replicatorArn", type = "string")), ReplicatorState = structure(logical(0), tags = list(locationName = "replicatorState", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_security_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClientAuthentication = structure(list(Sasl = structure(list(Scram = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "scram", type = "structure")), Iam = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "iam", type = "structure"))), tags = list(locationName = "sasl", type = "structure")), Tls = structure(list(CertificateAuthorityArnList = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(locationName = "certificateAuthorityArnList", type = "list")), Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "tls", type = "structure")), Unauthenticated = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean"))), tags = list(locationName = "unauthenticated", type = "structure"))), tags = list(locationName = "clientAuthentication", type = "structure")), ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), EncryptionInfo = structure(list(EncryptionAtRest = structure(list(DataVolumeKMSKeyId = structure(logical(0), tags = list(locationName = "dataVolumeKMSKeyId", type = "string"))), tags = list(locationName = "encryptionAtRest", type = "structure")), EncryptionInTransit = structure(list(ClientBroker = structure(logical(0), tags = list(locationName = "clientBroker", type = "string")), InCluster = structure(logical(0), tags = list(locationName = "inCluster", type = "boolean"))), tags = list(locationName = "encryptionInTransit", type = "structure"))), tags = list(locationName = "encryptionInfo", type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_security_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_storage_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(location = "uri", locationName = "clusterArn", type = "string")), CurrentVersion = structure(logical(0), tags = list(locationName = "currentVersion", type = "string")), ProvisionedThroughput = structure(list(Enabled = structure(logical(0), tags = list(locationName = "enabled", type = "boolean")), VolumeThroughput = structure(logical(0), tags = list(locationName = "volumeThroughput", type = "integer"))), tags = list(locationName = "provisionedThroughput", type = "structure")), StorageMode = structure(logical(0), tags = list(locationName = "storageMode", type = "string")), VolumeSizeGB = structure(logical(0), tags = list(locationName = "volumeSizeGB", type = "integer"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafka$update_storage_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ClusterArn = structure(logical(0), tags = list(locationName = "clusterArn", type = "string")), ClusterOperationArn = structure(logical(0), tags = list(locationName = "clusterOperationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}