aws-sdk-kafka 1.126.0

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
pub(crate) fn create_channel_output_output_correct_errors(
    mut builder: crate::operation::create_channel::builders::CreateChannelOutputBuilder,
) -> crate::operation::create_channel::builders::CreateChannelOutputBuilder {
    if builder.channel_arn.is_none() {
        builder.channel_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn delete_channel_output_output_correct_errors(
    mut builder: crate::operation::delete_channel::builders::DeleteChannelOutputBuilder,
) -> crate::operation::delete_channel::builders::DeleteChannelOutputBuilder {
    if builder.channel_arn.is_none() {
        builder.channel_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn describe_channel_output_output_correct_errors(
    mut builder: crate::operation::describe_channel::builders::DescribeChannelOutputBuilder,
) -> crate::operation::describe_channel::builders::DescribeChannelOutputBuilder {
    if builder.channel_arn.is_none() {
        builder.channel_arn = Some(Default::default())
    }
    if builder.channel_name.is_none() {
        builder.channel_name = Some(Default::default())
    }
    if builder.status.is_none() {
        builder.status = "no value was set".parse::<crate::types::ChannelStatus>().ok()
    }
    if builder.destination_type.is_none() {
        builder.destination_type = "no value was set".parse::<crate::types::ChannelDestinationType>().ok()
    }
    if builder.creation_time.is_none() {
        builder.creation_time = Some(::aws_smithy_types::DateTime::from_fractional_secs(0, 0_f64))
    }
    if builder.topic_configuration_list.is_none() {
        builder.topic_configuration_list = Some(Default::default())
    }
    builder
}

pub(crate) fn update_channel_output_output_correct_errors(
    mut builder: crate::operation::update_channel::builders::UpdateChannelOutputBuilder,
) -> crate::operation::update_channel::builders::UpdateChannelOutputBuilder {
    if builder.channel_arn.is_none() {
        builder.channel_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn configuration_revision_correct_errors(
    mut builder: crate::types::builders::ConfigurationRevisionBuilder,
) -> crate::types::builders::ConfigurationRevisionBuilder {
    if builder.creation_time.is_none() {
        builder.creation_time = Some(::aws_smithy_types::DateTime::from_fractional_secs(0, 0_f64))
    }
    if builder.revision.is_none() {
        builder.revision = Some(Default::default())
    }
    builder
}

pub(crate) fn encryption_configuration_correct_errors(
    mut builder: crate::types::builders::EncryptionConfigurationBuilder,
) -> crate::types::builders::EncryptionConfigurationBuilder {
    if builder.kms_key_arn.is_none() {
        builder.kms_key_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn iceberg_destination_configuration_correct_errors(
    mut builder: crate::types::builders::IcebergDestinationConfigurationBuilder,
) -> crate::types::builders::IcebergDestinationConfigurationBuilder {
    if builder.append_only.is_none() {
        builder.append_only = Some(Default::default())
    }
    if builder.dead_letter_queue_s3.is_none() {
        builder.dead_letter_queue_s3 = {
            let builder = crate::types::builders::DeadLetterQueueS3Builder::default();
            Some(crate::serde_util::dead_letter_queue_s3_correct_errors(builder).build())
        }
    }
    if builder.destination_table_list.is_none() {
        builder.destination_table_list = Some(Default::default())
    }
    if builder.schema_evolution.is_none() {
        builder.schema_evolution = {
            let builder = crate::types::builders::SchemaEvolutionBuilder::default();
            Some(builder.build())
        }
    }
    if builder.service_execution_role_arn.is_none() {
        builder.service_execution_role_arn = Some(Default::default())
    }
    if builder.table_creation.is_none() {
        builder.table_creation = {
            let builder = crate::types::builders::TableCreationBuilder::default();
            Some(builder.build())
        }
    }
    builder
}

pub(crate) fn s3_destination_configuration_correct_errors(
    mut builder: crate::types::builders::S3DestinationConfigurationBuilder,
) -> crate::types::builders::S3DestinationConfigurationBuilder {
    if builder.dead_letter_queue_s3.is_none() {
        builder.dead_letter_queue_s3 = {
            let builder = crate::types::builders::DeadLetterQueueS3Builder::default();
            Some(crate::serde_util::dead_letter_queue_s3_correct_errors(builder).build())
        }
    }
    if builder.service_execution_role_arn.is_none() {
        builder.service_execution_role_arn = Some(Default::default())
    }
    if builder.storage.is_none() {
        builder.storage = {
            let builder = crate::types::builders::S3StorageBuilder::default();
            Some(crate::serde_util::s3_storage_correct_errors(builder).build())
        }
    }
    builder
}

pub(crate) fn broker_node_group_info_correct_errors(
    mut builder: crate::types::builders::BrokerNodeGroupInfoBuilder,
) -> crate::types::builders::BrokerNodeGroupInfoBuilder {
    if builder.client_subnets.is_none() {
        builder.client_subnets = Some(Default::default())
    }
    if builder.instance_type.is_none() {
        builder.instance_type = Some(Default::default())
    }
    builder
}

pub(crate) fn channel_info_correct_errors(mut builder: crate::types::builders::ChannelInfoBuilder) -> crate::types::builders::ChannelInfoBuilder {
    if builder.channel_arn.is_none() {
        builder.channel_arn = Some(Default::default())
    }
    if builder.channel_name.is_none() {
        builder.channel_name = Some(Default::default())
    }
    if builder.status.is_none() {
        builder.status = "no value was set".parse::<crate::types::ChannelStatus>().ok()
    }
    if builder.creation_time.is_none() {
        builder.creation_time = Some(::aws_smithy_types::DateTime::from_fractional_secs(0, 0_f64))
    }
    if builder.destination_type.is_none() {
        builder.destination_type = "no value was set".parse::<crate::types::ChannelDestinationType>().ok()
    }
    builder
}

pub(crate) fn client_vpc_connection_correct_errors(
    mut builder: crate::types::builders::ClientVpcConnectionBuilder,
) -> crate::types::builders::ClientVpcConnectionBuilder {
    if builder.vpc_connection_arn.is_none() {
        builder.vpc_connection_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn cloud_watch_logs_correct_errors(
    mut builder: crate::types::builders::CloudWatchLogsBuilder,
) -> crate::types::builders::CloudWatchLogsBuilder {
    if builder.enabled.is_none() {
        builder.enabled = Some(Default::default())
    }
    builder
}

pub(crate) fn configuration_correct_errors(
    mut builder: crate::types::builders::ConfigurationBuilder,
) -> crate::types::builders::ConfigurationBuilder {
    if builder.arn.is_none() {
        builder.arn = Some(Default::default())
    }
    if builder.creation_time.is_none() {
        builder.creation_time = Some(::aws_smithy_types::DateTime::from_fractional_secs(0, 0_f64))
    }
    if builder.description.is_none() {
        builder.description = Some(Default::default())
    }
    if builder.kafka_versions.is_none() {
        builder.kafka_versions = Some(Default::default())
    }
    if builder.latest_revision.is_none() {
        builder.latest_revision = {
            let builder = crate::types::builders::ConfigurationRevisionBuilder::default();
            Some(crate::serde_util::configuration_revision_correct_errors(builder).build())
        }
    }
    if builder.name.is_none() {
        builder.name = Some(Default::default())
    }
    if builder.state.is_none() {
        builder.state = "no value was set".parse::<crate::types::ConfigurationState>().ok()
    }
    builder
}

pub(crate) fn dead_letter_queue_s3_correct_errors(
    mut builder: crate::types::builders::DeadLetterQueueS3Builder,
) -> crate::types::builders::DeadLetterQueueS3Builder {
    if builder.bucket_arn.is_none() {
        builder.bucket_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn firehose_correct_errors(mut builder: crate::types::builders::FirehoseBuilder) -> crate::types::builders::FirehoseBuilder {
    if builder.enabled.is_none() {
        builder.enabled = Some(Default::default())
    }
    builder
}

pub(crate) fn logging_info_correct_errors(mut builder: crate::types::builders::LoggingInfoBuilder) -> crate::types::builders::LoggingInfoBuilder {
    if builder.broker_logs.is_none() {
        builder.broker_logs = {
            let builder = crate::types::builders::BrokerLogsBuilder::default();
            Some(builder.build())
        }
    }
    builder
}

pub(crate) fn open_monitoring_correct_errors(
    mut builder: crate::types::builders::OpenMonitoringBuilder,
) -> crate::types::builders::OpenMonitoringBuilder {
    if builder.prometheus.is_none() {
        builder.prometheus = {
            let builder = crate::types::builders::PrometheusBuilder::default();
            Some(builder.build())
        }
    }
    builder
}

pub(crate) fn provisioned_correct_errors(mut builder: crate::types::builders::ProvisionedBuilder) -> crate::types::builders::ProvisionedBuilder {
    if builder.broker_node_group_info.is_none() {
        builder.broker_node_group_info = {
            let builder = crate::types::builders::BrokerNodeGroupInfoBuilder::default();
            Some(crate::serde_util::broker_node_group_info_correct_errors(builder).build())
        }
    }
    if builder.number_of_broker_nodes.is_none() {
        builder.number_of_broker_nodes = Some(Default::default())
    }
    builder
}

pub(crate) fn s3_correct_errors(mut builder: crate::types::builders::S3Builder) -> crate::types::builders::S3Builder {
    if builder.enabled.is_none() {
        builder.enabled = Some(Default::default())
    }
    builder
}

pub(crate) fn s3_storage_correct_errors(mut builder: crate::types::builders::S3StorageBuilder) -> crate::types::builders::S3StorageBuilder {
    if builder.bucket_arn.is_none() {
        builder.bucket_arn = Some(Default::default())
    }
    if builder.compression_type.is_none() {
        builder.compression_type = "no value was set".parse::<crate::types::S3CompressionType>().ok()
    }
    if builder.storage_class.is_none() {
        builder.storage_class = "no value was set".parse::<crate::types::S3StorageClass>().ok()
    }
    builder
}

pub(crate) fn serverless_correct_errors(mut builder: crate::types::builders::ServerlessBuilder) -> crate::types::builders::ServerlessBuilder {
    if builder.vpc_configs.is_none() {
        builder.vpc_configs = Some(Default::default())
    }
    builder
}

pub(crate) fn topic_configuration_correct_errors(
    mut builder: crate::types::builders::TopicConfigurationBuilder,
) -> crate::types::builders::TopicConfigurationBuilder {
    if builder.record_converter.is_none() {
        builder.record_converter = {
            let builder = crate::types::builders::RecordConverterBuilder::default();
            Some(crate::serde_util::record_converter_correct_errors(builder).build())
        }
    }
    if builder.topic_arn.is_none() {
        builder.topic_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn vpc_connection_correct_errors(
    mut builder: crate::types::builders::VpcConnectionBuilder,
) -> crate::types::builders::VpcConnectionBuilder {
    if builder.vpc_connection_arn.is_none() {
        builder.vpc_connection_arn = Some(Default::default())
    }
    if builder.target_cluster_arn.is_none() {
        builder.target_cluster_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn amazon_msk_cluster_correct_errors(
    mut builder: crate::types::builders::AmazonMskClusterBuilder,
) -> crate::types::builders::AmazonMskClusterBuilder {
    if builder.msk_cluster_arn.is_none() {
        builder.msk_cluster_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn apache_kafka_cluster_correct_errors(
    mut builder: crate::types::builders::ApacheKafkaClusterBuilder,
) -> crate::types::builders::ApacheKafkaClusterBuilder {
    if builder.apache_kafka_cluster_id.is_none() {
        builder.apache_kafka_cluster_id = Some(Default::default())
    }
    if builder.bootstrap_broker_string.is_none() {
        builder.bootstrap_broker_string = Some(Default::default())
    }
    builder
}

pub(crate) fn configuration_info_correct_errors(
    mut builder: crate::types::builders::ConfigurationInfoBuilder,
) -> crate::types::builders::ConfigurationInfoBuilder {
    if builder.arn.is_none() {
        builder.arn = Some(Default::default())
    }
    if builder.revision.is_none() {
        builder.revision = Some(Default::default())
    }
    builder
}

pub(crate) fn consumer_group_replication_correct_errors(
    mut builder: crate::types::builders::ConsumerGroupReplicationBuilder,
) -> crate::types::builders::ConsumerGroupReplicationBuilder {
    if builder.consumer_groups_to_replicate.is_none() {
        builder.consumer_groups_to_replicate = Some(Default::default())
    }
    builder
}

pub(crate) fn encryption_at_rest_correct_errors(
    mut builder: crate::types::builders::EncryptionAtRestBuilder,
) -> crate::types::builders::EncryptionAtRestBuilder {
    if builder.data_volume_kms_key_id.is_none() {
        builder.data_volume_kms_key_id = Some(Default::default())
    }
    builder
}

pub(crate) fn kafka_cluster_client_vpc_config_correct_errors(
    mut builder: crate::types::builders::KafkaClusterClientVpcConfigBuilder,
) -> crate::types::builders::KafkaClusterClientVpcConfigBuilder {
    if builder.subnet_ids.is_none() {
        builder.subnet_ids = Some(Default::default())
    }
    builder
}

pub(crate) fn kafka_cluster_encryption_in_transit_correct_errors(
    mut builder: crate::types::builders::KafkaClusterEncryptionInTransitBuilder,
) -> crate::types::builders::KafkaClusterEncryptionInTransitBuilder {
    if builder.encryption_type.is_none() {
        builder.encryption_type = "no value was set".parse::<crate::types::KafkaClusterEncryptionInTransitType>().ok()
    }
    builder
}

pub(crate) fn open_monitoring_info_correct_errors(
    mut builder: crate::types::builders::OpenMonitoringInfoBuilder,
) -> crate::types::builders::OpenMonitoringInfoBuilder {
    if builder.prometheus.is_none() {
        builder.prometheus = {
            let builder = crate::types::builders::PrometheusInfoBuilder::default();
            Some(builder.build())
        }
    }
    builder
}

pub(crate) fn record_converter_correct_errors(
    mut builder: crate::types::builders::RecordConverterBuilder,
) -> crate::types::builders::RecordConverterBuilder {
    if builder.value_converter.is_none() {
        builder.value_converter = "no value was set".parse::<crate::types::ValueConverter>().ok()
    }
    builder
}

pub(crate) fn record_schema_correct_errors(mut builder: crate::types::builders::RecordSchemaBuilder) -> crate::types::builders::RecordSchemaBuilder {
    if builder.gsr_arn.is_none() {
        builder.gsr_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn replicator_cloud_watch_logs_correct_errors(
    mut builder: crate::types::builders::ReplicatorCloudWatchLogsBuilder,
) -> crate::types::builders::ReplicatorCloudWatchLogsBuilder {
    if builder.enabled.is_none() {
        builder.enabled = Some(Default::default())
    }
    builder
}

pub(crate) fn replicator_firehose_correct_errors(
    mut builder: crate::types::builders::ReplicatorFirehoseBuilder,
) -> crate::types::builders::ReplicatorFirehoseBuilder {
    if builder.enabled.is_none() {
        builder.enabled = Some(Default::default())
    }
    builder
}

pub(crate) fn replicator_s3_correct_errors(mut builder: crate::types::builders::ReplicatorS3Builder) -> crate::types::builders::ReplicatorS3Builder {
    if builder.enabled.is_none() {
        builder.enabled = Some(Default::default())
    }
    builder
}

pub(crate) fn topic_replication_correct_errors(
    mut builder: crate::types::builders::TopicReplicationBuilder,
) -> crate::types::builders::TopicReplicationBuilder {
    if builder.topics_to_replicate.is_none() {
        builder.topics_to_replicate = Some(Default::default())
    }
    builder
}

pub(crate) fn broker_ebs_volume_info_correct_errors(
    mut builder: crate::types::builders::BrokerEbsVolumeInfoBuilder,
) -> crate::types::builders::BrokerEbsVolumeInfoBuilder {
    if builder.kafka_broker_node_id.is_none() {
        builder.kafka_broker_node_id = Some(Default::default())
    }
    builder
}

pub(crate) fn jmx_exporter_correct_errors(mut builder: crate::types::builders::JmxExporterBuilder) -> crate::types::builders::JmxExporterBuilder {
    if builder.enabled_in_broker.is_none() {
        builder.enabled_in_broker = Some(Default::default())
    }
    builder
}

pub(crate) fn kafka_cluster_mtls_authentication_correct_errors(
    mut builder: crate::types::builders::KafkaClusterMtlsAuthenticationBuilder,
) -> crate::types::builders::KafkaClusterMtlsAuthenticationBuilder {
    if builder.secret_arn.is_none() {
        builder.secret_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn kafka_cluster_sasl_o_auth_bearer_authentication_correct_errors(
    mut builder: crate::types::builders::KafkaClusterSaslOAuthBearerAuthenticationBuilder,
) -> crate::types::builders::KafkaClusterSaslOAuthBearerAuthenticationBuilder {
    if builder.token_endpoint_url.is_none() {
        builder.token_endpoint_url = Some(Default::default())
    }
    if builder.token_endpoint_authentication_method.is_none() {
        builder.token_endpoint_authentication_method = "no value was set".parse::<crate::types::TokenEndpointAuthenticationMethod>().ok()
    }
    builder
}

pub(crate) fn kafka_cluster_sasl_scram_authentication_correct_errors(
    mut builder: crate::types::builders::KafkaClusterSaslScramAuthenticationBuilder,
) -> crate::types::builders::KafkaClusterSaslScramAuthenticationBuilder {
    if builder.mechanism.is_none() {
        builder.mechanism = "no value was set".parse::<crate::types::KafkaClusterSaslScramMechanism>().ok()
    }
    if builder.secret_arn.is_none() {
        builder.secret_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn node_exporter_correct_errors(mut builder: crate::types::builders::NodeExporterBuilder) -> crate::types::builders::NodeExporterBuilder {
    if builder.enabled_in_broker.is_none() {
        builder.enabled_in_broker = Some(Default::default())
    }
    builder
}

pub(crate) fn partition_spec_correct_errors(
    mut builder: crate::types::builders::PartitionSpecBuilder,
) -> crate::types::builders::PartitionSpecBuilder {
    if builder.partition_strategy.is_none() {
        builder.partition_strategy = "no value was set".parse::<crate::types::PartitionStrategy>().ok()
    }
    builder
}

pub(crate) fn vpc_config_correct_errors(mut builder: crate::types::builders::VpcConfigBuilder) -> crate::types::builders::VpcConfigBuilder {
    if builder.subnet_ids.is_none() {
        builder.subnet_ids = Some(Default::default())
    }
    builder
}

pub(crate) fn jmx_exporter_info_correct_errors(
    mut builder: crate::types::builders::JmxExporterInfoBuilder,
) -> crate::types::builders::JmxExporterInfoBuilder {
    if builder.enabled_in_broker.is_none() {
        builder.enabled_in_broker = Some(Default::default())
    }
    builder
}

pub(crate) fn kafka_cluster_o_auth_client_credentials_correct_errors(
    mut builder: crate::types::builders::KafkaClusterOAuthClientCredentialsBuilder,
) -> crate::types::builders::KafkaClusterOAuthClientCredentialsBuilder {
    if builder.token_request_secret_arn.is_none() {
        builder.token_request_secret_arn = Some(Default::default())
    }
    builder
}

pub(crate) fn kafka_cluster_o_auth_client_credentials_assertion_correct_errors(
    mut builder: crate::types::builders::KafkaClusterOAuthClientCredentialsAssertionBuilder,
) -> crate::types::builders::KafkaClusterOAuthClientCredentialsAssertionBuilder {
    if builder.audience.is_none() {
        builder.audience = Some(Default::default())
    }
    if builder.signing_algorithm.is_none() {
        builder.signing_algorithm = "no value was set".parse::<crate::types::JwtSigningAlgorithm>().ok()
    }
    builder
}

pub(crate) fn kafka_cluster_o_auth_iam_jwt_bearer_correct_errors(
    mut builder: crate::types::builders::KafkaClusterOAuthIamJwtBearerBuilder,
) -> crate::types::builders::KafkaClusterOAuthIamJwtBearerBuilder {
    if builder.audience.is_none() {
        builder.audience = Some(Default::default())
    }
    if builder.signing_algorithm.is_none() {
        builder.signing_algorithm = "no value was set".parse::<crate::types::JwtSigningAlgorithm>().ok()
    }
    builder
}

pub(crate) fn node_exporter_info_correct_errors(
    mut builder: crate::types::builders::NodeExporterInfoBuilder,
) -> crate::types::builders::NodeExporterInfoBuilder {
    if builder.enabled_in_broker.is_none() {
        builder.enabled_in_broker = Some(Default::default())
    }
    builder
}