Skip to content

update_topic async 

update_topic(
    cluster_arn: __string,
    topic_name: __string,
    *,
    config_overrides: Optional[AsyncKafkaClientConfig] = None,
    configs: Optional[__string] = None,
    partition_count: Optional[__integer] = None,
) -> UpdateTopicResponse

Updates the configuration of the specified topic.

Parameters:

  • cluster_arn (__string) –

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

  • topic_name (__string) –

    The name of the topic to update configuration for.

  • configs (Optional[__string], default: None ) –

    The new topic configurations encoded as a Base64 string.

  • partition_count (Optional[__integer], default: None ) –

    The new total number of partitions for the topic.

Raises:

Source code in docs_src/capo_kafka/_services/async_kafka.py 
4443
4444
4445
4446
4447
4448
4449
4450
4451
4452
4453
4454
4455
4456
4457
4458
4459
4460
4461
4462
4463
4464
4465
4466
4467
4468
4469
4470
4471
4472
4473
4474
4475
4476
4477
4478
4479
4480
4481
4482
4483
4484
4485
4486
4487
4488
4489
4490
4491
4492
4493
4494
4495
4496
4497
4498
4499
4500
4501
4502
4503
4504
4505
4506
4507
4508
4509
4510
4511
async def update_topic(
    self,
    cluster_arn: "capo_kafka.types.__string.__string",
    topic_name: "capo_kafka.types.__string.__string",
    *,
    config_overrides: Optional[AsyncKafkaClientConfig] = None,
    configs: Optional["capo_kafka.types.__string.__string"] = None,
    partition_count: Optional["capo_kafka.types.__integer.__integer"] = None,
) -> "capo_kafka.types.update_topic_response.UpdateTopicResponse":
    """<p>Updates the configuration of the specified topic.</p>

    Args:
        cluster_arn: <p>The Amazon Resource Name (ARN) that uniquely identifies the cluster.</p>
        topic_name: <p>The name of the topic to update configuration for.</p>
        configs: <p>The new topic configurations encoded as a Base64 string.</p>
        partition_count: <p>The new total number of partitions for the topic.</p>

    Raises:
        capo_kafka.errors.bad_request_exception.BadRequestException: <p>Returns information about an error.</p>
        capo_kafka.errors.cluster_connectivity_exception.ClusterConnectivityException: <p>Returns information about an error.</p>
        capo_kafka.errors.controller_moved_exception.ControllerMovedException: <p>Returns information about an error.</p>
        capo_kafka.errors.forbidden_exception.ForbiddenException: <p>Returns information about an error.</p>
        capo_kafka.errors.group_subscribed_to_topic_exception.GroupSubscribedToTopicException: <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.kafka_request_exception.KafkaRequestException: <p>Returns information about an error.</p>
        capo_kafka.errors.kafka_timeout_exception.KafkaTimeoutException: <p>Returns information about an error.</p>
        capo_kafka.errors.not_controller_exception.NotControllerException: <p>Returns information about an error.</p>
        capo_kafka.errors.not_found_exception.NotFoundException: <p>Returns information about an error.</p>
        capo_kafka.errors.reassignment_in_progress_exception.ReassignmentInProgressException: <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.unknown_topic_or_partition_exception.UnknownTopicOrPartitionException: <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_topic_request.UpdateTopicRequest]",
    ) -> AsyncOperationResponse[
        "capo_kafka.types.update_topic_response.UpdateTopicResponse"
    ]:
        import capo_kafka._operations.kafka.update_topic

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

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("UpdateTopic")
    )
    input_: capo_kafka.types.update_topic_request.UpdateTopicRequest = {
        "cluster_arn": cluster_arn,
        "topic_name": topic_name,
    }
    if configs is not None:
        input_["configs"] = configs
    if partition_count is not None:
        input_["partition_count"] = partition_count

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