update_configuration async ¶

async def update_configuration(
    self,
    arn: "capo_kafka.types.__string.__string",
    *,
    config_overrides: Optional[AsyncKafkaClientConfig] = None,
    description: Optional["capo_kafka.types.__string.__string"] = None,
    server_properties: Optional["capo_kafka.types.__blob.__blob"] = None,
) -> "capo_kafka.types.update_configuration_response.UpdateConfigurationResponse":
    """<p>Updates an MSK configuration.</p>

    Args:
        arn: <p>The Amazon Resource Name (ARN) of the configuration.</p>
        description: <p>The description of the configuration revision.</p>
        server_properties: <p>Contents of the <filename>server.properties</filename> file. When using the API, you must ensure that the contents of the file are base64 encoded. When using the AWS Management Console, the SDK, or the AWS CLI, the contents of <filename>server.properties</filename> can be in plaintext.</p>

    Raises:
        capo_kafka.errors.bad_request_exception.BadRequestException: <p>Returns information about an error.</p>
        capo_kafka.errors.forbidden_exception.ForbiddenException: <p>Returns information about an error.</p>
        capo_kafka.errors.internal_server_error_exception.InternalServerErrorException: <p>Returns information about an error.</p>
        capo_kafka.errors.not_found_exception.NotFoundException: <p>Returns information about an error.</p>
        capo_kafka.errors.service_unavailable_exception.ServiceUnavailableException: <p>Returns information about an error.</p>
        capo_kafka.errors.unauthorized_exception.UnauthorizedException: <p>Returns information about an error.</p>
        capo_kafka.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_kafka.types.update_configuration_request.UpdateConfigurationRequest]",
    ) -> AsyncOperationResponse[
        "capo_kafka.types.update_configuration_response.UpdateConfigurationResponse"
    ]:
        import capo_kafka._operations.kafka.update_configuration

        (
            output,
            http_response,
        ) = await capo_kafka._operations.kafka.update_configuration.async_update_configuration(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("UpdateConfiguration")
    )
    input_: capo_kafka.types.update_configuration_request.UpdateConfigurationRequest = {
        "arn": arn
    }
    if description is not None:
        input_["description"] = description
    if server_properties is not None:
        input_["server_properties"] = server_properties

    response = await aexecute_pipeline(
        AsyncOperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    await response.response.aclose()
    return response.output