Console
    Start free

    Package Methods (0.4.0)

    Summary of entries of Methods for google-cloud-managedkafka.

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient

      ManagedKafkaAsyncClient 
 ( 
 * 
 , 
 credentials 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 auth 
 . 
 credentials 
 . 
 Credentials 
 ] 
 = 
 None 
 , 
 transport 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaTransport 
 , 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaTransport 
 , 
 ], 
 ] 
 ] 
 = 
 "grpc_asyncio" 
 , 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 , 
 client_info 
 : 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 client_info 
 . 
 ClientInfo 
 = 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 client_info 
 . 
 ClientInfo 
 )

    Instantiates the managed kafka async client.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.acl_path

      acl_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 cluster 
 : 
 str 
 , 
 acl 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified acl string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.acl_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.add_acl_entry

      add_acl_entry 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 AddAclEntryRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 acl 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 acl_entry 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 AclEntry 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 AddAclEntryResponse

    Incremental update: Adds an acl entry to an acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.add_acl_entry

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.ca_pool_path

      ca_pool_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 ca_pool 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified ca_pool string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.ca_pool_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.cancel_operation

      cancel_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 CancelOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Starts asynchronous cancellation on a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.cancel_operation

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.cluster_path

      cluster_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 cluster 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified cluster string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.cluster_path 

      common_billing_account_path 
 ( 
 billing_account 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified billing_account string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_billing_account_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_folder_path

      common_folder_path 
 ( 
 folder 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified folder string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_folder_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_location_path

      common_location_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified location string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_location_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_organization_path

      common_organization_path 
 ( 
 organization 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified organization string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_organization_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_project_path

      common_project_path 
 ( 
 project 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified project string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_project_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.consumer_group_path

      consumer_group_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 cluster 
 : 
 str 
 , 
 consumer_group 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified consumer_group string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.consumer_group_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.create_acl

      create_acl 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 CreateAclRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 acl 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl 
 ] 
 = 
 None 
 , 
 acl_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl

    Creates a new acl in the given project, location, and cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.create_acl

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.create_cluster

      create_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 CreateClusterRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 cluster 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Cluster 
 ] 
 = 
 None 
 , 
 cluster_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation_async 
 . 
 AsyncOperation

    Creates a new cluster in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.create_cluster

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.create_topic

      create_topic 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 CreateTopicRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 topic 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic 
 ] 
 = 
 None 
 , 
 topic_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic

    Creates a new topic in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.create_topic

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.crypto_key_path

      crypto_key_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 key_ring 
 : 
 str 
 , 
 crypto_key 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified crypto_key string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.crypto_key_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_acl

      delete_acl 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 DeleteAclRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes an acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_acl

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_cluster

      delete_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 DeleteClusterRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation_async 
 . 
 AsyncOperation

    Deletes a single cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_cluster

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_consumer_group

      delete_consumer_group 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 DeleteConsumerGroupRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a single consumer group.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_consumer_group

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_operation

      delete_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 DeleteOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_operation

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_topic

      delete_topic 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 DeleteTopicRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a single topic.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_topic 

      from_service_account_file 
 ( 
 filename 
 : 
 str 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials file.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.from_service_account_file 

      from_service_account_info 
 ( 
 info 
 : 
 dict 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials info.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.from_service_account_info 

      from_service_account_json 
 ( 
 filename 
 : 
 str 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials file.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.from_service_account_json

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_acl

      get_acl 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 GetAclRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl

    Returns the properties of a single acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_acl

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_cluster

      get_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 GetClusterRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Cluster

    Returns the properties of a single cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_cluster

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_consumer_group

      get_consumer_group 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 GetConsumerGroupRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConsumerGroup

    Returns the properties of a single consumer group.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_consumer_group

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_location

      get_location 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 GetLocationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 Location

    Gets information about a location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_location

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_mtls_endpoint_and_cert_source

      get_mtls_endpoint_and_cert_source 
 ( 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 , 
 )

    Return the API endpoint and client cert source for mutual TLS.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_mtls_endpoint_and_cert_source

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_operation

      get_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 GetOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 Operation

    Gets the latest state of a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_operation

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_topic

      get_topic 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 GetTopicRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic

    Returns the properties of a single topic.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_topic

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_transport_class

      get_transport_class 
 ( 
 label 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 ) 
 - 
> typing 
 . 
 Type 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaTransport 
 ]

    Returns an appropriate transport class.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_transport_class

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_acls

      list_acls 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListAclsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 pagers 
 . 
 ListAclsAsyncPager

    Lists the acls in a given cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_acls

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_clusters

      list_clusters 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListClustersRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 pagers 
 . 
 ListClustersAsyncPager

    Lists the clusters in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_clusters

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_consumer_groups

      list_consumer_groups 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListConsumerGroupsRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> ( 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 pagers 
 . 
 ListConsumerGroupsAsyncPager 
 )

    Lists the consumer groups in a given cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_consumer_groups

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_locations

      list_locations 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 ListLocationsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 ListLocationsResponse

    Lists information about the supported locations for this service.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_locations

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_operations

      list_operations 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 ListOperationsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 ListOperationsResponse

    Lists operations that match the specified filter in the request.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_operations

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_topics

      list_topics 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListTopicsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 pagers 
 . 
 ListTopicsAsyncPager

    Lists the topics in a given cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.list_topics

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_acl_path

      parse_acl_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a acl path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_acl_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_ca_pool_path

      parse_ca_pool_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a ca_pool path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_ca_pool_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_cluster_path

      parse_cluster_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a cluster path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_cluster_path 

      parse_common_billing_account_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a billing_account path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_billing_account_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_folder_path

      parse_common_folder_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a folder path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_folder_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_location_path

      parse_common_location_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a location path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_location_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_organization_path

      parse_common_organization_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a organization path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_organization_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_project_path

      parse_common_project_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a project path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_project_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_consumer_group_path

      parse_consumer_group_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a consumer_group path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_consumer_group_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_crypto_key_path

      parse_crypto_key_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a crypto_key path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_crypto_key_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_topic_path

      parse_topic_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a topic path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_topic_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.remove_acl_entry

      remove_acl_entry 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 RemoveAclEntryRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 acl 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 acl_entry 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 AclEntry 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 RemoveAclEntryResponse

    Incremental update: Removes an acl entry from an acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.remove_acl_entry

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.topic_path

      topic_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 cluster 
 : 
 str 
 , 
 topic 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified topic string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.topic_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.update_acl

      update_acl 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 UpdateAclRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 acl 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl

    Updates the properties of a single acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.update_acl

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.update_cluster

      update_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 UpdateClusterRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 cluster 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Cluster 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation_async 
 . 
 AsyncOperation

    Updates the properties of a single cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.update_cluster

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.update_consumer_group

      update_consumer_group 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 UpdateConsumerGroupRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 consumer_group 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConsumerGroup 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConsumerGroup

    Updates the properties of a single consumer group.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.update_consumer_group

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.update_topic

      update_topic 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 UpdateTopicRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 topic 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic

    Updates the properties of a single topic.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.update_topic

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient

      ManagedKafkaClient 
 ( 
 * 
 , 
 credentials 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 auth 
 . 
 credentials 
 . 
 Credentials 
 ] 
 = 
 None 
 , 
 transport 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaTransport 
 , 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaTransport 
 , 
 ], 
 ] 
 ] 
 = 
 None 
 , 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 client_info 
 : 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 client_info 
 . 
 ClientInfo 
 = 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 client_info 
 . 
 ClientInfo 
 )

    Instantiates the managed kafka client.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.__exit__

      __exit__ 
 ( 
 type 
 , 
 value 
 , 
 traceback 
 )

    Releases underlying transport's resources.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient. exit

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.acl_path

      acl_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 cluster 
 : 
 str 
 , 
 acl 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified acl string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.acl_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.add_acl_entry

      add_acl_entry 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 AddAclEntryRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 acl 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 acl_entry 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 AclEntry 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 AddAclEntryResponse

    Incremental update: Adds an acl entry to an acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.add_acl_entry

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.ca_pool_path

      ca_pool_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 ca_pool 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified ca_pool string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.ca_pool_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.cancel_operation

      cancel_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 CancelOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Starts asynchronous cancellation on a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.cancel_operation

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.cluster_path

      cluster_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 cluster 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified cluster string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.cluster_path 

      common_billing_account_path 
 ( 
 billing_account 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified billing_account string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_billing_account_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_folder_path

      common_folder_path 
 ( 
 folder 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified folder string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_folder_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_location_path

      common_location_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified location string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_location_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_organization_path

      common_organization_path 
 ( 
 organization 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified organization string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_organization_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_project_path

      common_project_path 
 ( 
 project 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified project string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_project_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.consumer_group_path

      consumer_group_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 cluster 
 : 
 str 
 , 
 consumer_group 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified consumer_group string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.consumer_group_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.create_acl

      create_acl 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 CreateAclRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 acl 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl 
 ] 
 = 
 None 
 , 
 acl_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl

    Creates a new acl in the given project, location, and cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.create_acl

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.create_cluster

      create_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 CreateClusterRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 cluster 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Cluster 
 ] 
 = 
 None 
 , 
 cluster_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation 
 . 
 Operation

    Creates a new cluster in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.create_cluster

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.create_topic

      create_topic 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 CreateTopicRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 topic 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic 
 ] 
 = 
 None 
 , 
 topic_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic

    Creates a new topic in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.create_topic

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.crypto_key_path

      crypto_key_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 key_ring 
 : 
 str 
 , 
 crypto_key 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified crypto_key string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.crypto_key_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_acl

      delete_acl 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 DeleteAclRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes an acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_acl

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_cluster

      delete_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 DeleteClusterRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation 
 . 
 Operation

    Deletes a single cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_cluster

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_consumer_group

      delete_consumer_group 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 DeleteConsumerGroupRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a single consumer group.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_consumer_group

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_operation

      delete_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 DeleteOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_operation

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_topic

      delete_topic 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 DeleteTopicRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a single topic.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_topic 

      from_service_account_file 
 ( 
 filename 
 : 
 str 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials file.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.from_service_account_file 

      from_service_account_info 
 ( 
 info 
 : 
 dict 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials info.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.from_service_account_info 

      from_service_account_json 
 ( 
 filename 
 : 
 str 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials file.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.from_service_account_json

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_acl

      get_acl 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 GetAclRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl

    Returns the properties of a single acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_acl

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_cluster

      get_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 GetClusterRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Cluster

    Returns the properties of a single cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_cluster

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_consumer_group

      get_consumer_group 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 GetConsumerGroupRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConsumerGroup

    Returns the properties of a single consumer group.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_consumer_group

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_location

      get_location 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 GetLocationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 Location

    Gets information about a location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_location

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_mtls_endpoint_and_cert_source

      get_mtls_endpoint_and_cert_source 
 ( 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 , 
 )

    Deprecated.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_mtls_endpoint_and_cert_source

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_operation

      get_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 GetOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 Operation

    Gets the latest state of a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_operation

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_topic

      get_topic 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 GetTopicRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic

    Returns the properties of a single topic.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_topic

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_acls

      list_acls 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListAclsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 pagers 
 . 
 ListAclsPager

    Lists the acls in a given cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_acls

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_clusters

      list_clusters 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListClustersRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 pagers 
 . 
 ListClustersPager

    Lists the clusters in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_clusters

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_consumer_groups

      list_consumer_groups 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListConsumerGroupsRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 pagers 
 . 
 ListConsumerGroupsPager

    Lists the consumer groups in a given cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_consumer_groups

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_locations

      list_locations 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 ListLocationsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 ListLocationsResponse

    Lists information about the supported locations for this service.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_locations

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_operations

      list_operations 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 ListOperationsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 ListOperationsResponse

    Lists operations that match the specified filter in the request.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_operations

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_topics

      list_topics 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListTopicsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka 
 . 
 pagers 
 . 
 ListTopicsPager

    Lists the topics in a given cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.list_topics

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_acl_path

      parse_acl_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a acl path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_acl_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_ca_pool_path

      parse_ca_pool_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a ca_pool path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_ca_pool_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_cluster_path

      parse_cluster_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a cluster path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_cluster_path 

      parse_common_billing_account_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a billing_account path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_billing_account_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_folder_path

      parse_common_folder_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a folder path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_folder_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_location_path

      parse_common_location_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a location path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_location_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_organization_path

      parse_common_organization_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a organization path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_organization_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_project_path

      parse_common_project_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a project path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_project_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_consumer_group_path

      parse_consumer_group_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a consumer_group path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_consumer_group_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_crypto_key_path

      parse_crypto_key_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a crypto_key path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_crypto_key_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_topic_path

      parse_topic_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a topic path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_topic_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.remove_acl_entry

      remove_acl_entry 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 RemoveAclEntryRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 acl 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 acl_entry 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 AclEntry 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 RemoveAclEntryResponse

    Incremental update: Removes an acl entry from an acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.remove_acl_entry

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.topic_path

      topic_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 cluster 
 : 
 str 
 , 
 topic 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified topic string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.topic_path

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.update_acl

      update_acl 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 UpdateAclRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 acl 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Acl

    Updates the properties of a single acl.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.update_acl

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.update_cluster

      update_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 UpdateClusterRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 cluster 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Cluster 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation 
 . 
 Operation

    Updates the properties of a single cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.update_cluster

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.update_consumer_group

      update_consumer_group 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 UpdateConsumerGroupRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 consumer_group 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConsumerGroup 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConsumerGroup

    Updates the properties of a single consumer group.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.update_consumer_group

    google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.update_topic

      update_topic 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 UpdateTopicRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 topic 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Topic

    Updates the properties of a single topic.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.update_topic

    google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListAclsAsyncPager

      ListAclsAsyncPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 typing 
 . 
 Awaitable 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListAclsResponse 
 ], 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListAclsRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListAclsResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiates the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListAclsAsyncPager

    google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListAclsPager

      ListAclsPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListAclsResponse 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListAclsRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListAclsResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiate the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListAclsPager

    google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListClustersAsyncPager

      ListClustersAsyncPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 typing 
 . 
 Awaitable 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListClustersResponse 
 ], 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListClustersRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListClustersResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiates the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListClustersAsyncPager

    google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListClustersPager

      ListClustersPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListClustersResponse 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListClustersRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListClustersResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiate the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListClustersPager

    google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListConsumerGroupsAsyncPager

      ListConsumerGroupsAsyncPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 typing 
 . 
 Awaitable 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListConsumerGroupsResponse 
 ], 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListConsumerGroupsRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListConsumerGroupsResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiates the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListConsumerGroupsAsyncPager

    google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListConsumerGroupsPager

      ListConsumerGroupsPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListConsumerGroupsResponse 
 , 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListConsumerGroupsRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListConsumerGroupsResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiate the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListConsumerGroupsPager

    google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListTopicsAsyncPager

      ListTopicsAsyncPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 typing 
 . 
 Awaitable 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListTopicsResponse 
 ], 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListTopicsRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListTopicsResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiates the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListTopicsAsyncPager

    google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListTopicsPager

      ListTopicsPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListTopicsResponse 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListTopicsRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka 
 . 
 ListTopicsResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiate the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka.pagers.ListTopicsPager

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient

      ManagedKafkaConnectAsyncClient 
 ( 
 * 
 , 
 credentials 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 auth 
 . 
 credentials 
 . 
 Credentials 
 ] 
 = 
 None 
 , 
 transport 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka_connect 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaConnectTransport 
 , 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka_connect 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaConnectTransport 
 , 
 ], 
 ] 
 ] 
 = 
 "grpc_asyncio" 
 , 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 , 
 client_info 
 : 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 client_info 
 . 
 ClientInfo 
 = 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 client_info 
 . 
 ClientInfo 
 )

    Instantiates the managed kafka connect async client.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.cancel_operation

      cancel_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 CancelOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Starts asynchronous cancellation on a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.cancel_operation 

      common_billing_account_path 
 ( 
 billing_account 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified billing_account string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_billing_account_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_folder_path

      common_folder_path 
 ( 
 folder 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified folder string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_folder_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_location_path

      common_location_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified location string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_location_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_organization_path

      common_organization_path 
 ( 
 organization 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified organization string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_organization_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_project_path

      common_project_path 
 ( 
 project 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified project string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_project_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.connect_cluster_path

      connect_cluster_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 connect_cluster 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified connect_cluster string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.connect_cluster_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.connector_path

      connector_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 connect_cluster 
 : 
 str 
 , 
 connector 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified connector string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.connector_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.create_connect_cluster

      create_connect_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 CreateConnectClusterRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 connect_cluster 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConnectCluster 
 ] 
 = 
 None 
 , 
 connect_cluster_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation_async 
 . 
 AsyncOperation

    Creates a new Kafka Connect cluster in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.create_connect_cluster

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.create_connector

      create_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 CreateConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 connector 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector 
 ] 
 = 
 None 
 , 
 connector_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector

    Creates a new connector in a given Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.create_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.delete_connect_cluster

      delete_connect_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 DeleteConnectClusterRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation_async 
 . 
 AsyncOperation

    Deletes a single Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.delete_connect_cluster

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.delete_connector

      delete_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 DeleteConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.delete_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.delete_operation

      delete_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 DeleteOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.delete_operation 

      from_service_account_file 
 ( 
 filename 
 : 
 str 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials file.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.from_service_account_file 

      from_service_account_info 
 ( 
 info 
 : 
 dict 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials info.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.from_service_account_info 

      from_service_account_json 
 ( 
 filename 
 : 
 str 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials file.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.from_service_account_json

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_connect_cluster

      get_connect_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 GetConnectClusterRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConnectCluster

    Returns the properties of a single Kafka Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_connect_cluster

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_connector

      get_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 GetConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector

    Returns the properties of a single connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_location

      get_location 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 GetLocationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 Location

    Gets information about a location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_location

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_mtls_endpoint_and_cert_source

      get_mtls_endpoint_and_cert_source 
 ( 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 , 
 )

    Return the API endpoint and client cert source for mutual TLS.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_mtls_endpoint_and_cert_source

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_operation

      get_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 GetOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 Operation

    Gets the latest state of a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_operation

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_transport_class

      get_transport_class 
 ( 
 label 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 ) 
 - 
> typing 
 . 
 Type 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka_connect 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaConnectTransport 
 ]

    Returns an appropriate transport class.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_transport_class

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_connect_clusters

      list_connect_clusters 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectClustersRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> ( 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka_connect 
 . 
 pagers 
 . 
 ListConnectClustersAsyncPager 
 )

    Lists the Kafka Connect clusters in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_connect_clusters

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_connectors

      list_connectors 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectorsRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> ( 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka_connect 
 . 
 pagers 
 . 
 ListConnectorsAsyncPager 
 )

    Lists the connectors in a given Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_connectors

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_locations

      list_locations 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 ListLocationsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 ListLocationsResponse

    Lists information about the supported locations for this service.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_locations

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_operations

      list_operations 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 ListOperationsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 ListOperationsResponse

    Lists operations that match the specified filter in the request.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_operations 

      parse_common_billing_account_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a billing_account path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_billing_account_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_folder_path

      parse_common_folder_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a folder path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_folder_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_location_path

      parse_common_location_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a location path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_location_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_organization_path

      parse_common_organization_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a organization path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_organization_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_project_path

      parse_common_project_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a project path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_project_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_connect_cluster_path

      parse_connect_cluster_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a connect_cluster path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_connect_cluster_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_connector_path

      parse_connector_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a connector path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_connector_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_secret_version_path

      parse_secret_version_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a secret_version path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_secret_version_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.pause_connector

      pause_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 PauseConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 PauseConnectorResponse

    Pauses the connector and its tasks.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.pause_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.restart_connector

      restart_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 RestartConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 RestartConnectorResponse

    Restarts the connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.restart_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.resume_connector

      resume_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ResumeConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ResumeConnectorResponse

    Resumes the connector and its tasks.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.resume_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.secret_version_path

      secret_version_path 
 ( 
 project 
 : 
 str 
 , 
 secret 
 : 
 str 
 , 
 secret_version 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified secret_version string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.secret_version_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.stop_connector

      stop_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 StopConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 StopConnectorResponse

    Stops the connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.stop_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.update_connect_cluster

      update_connect_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 UpdateConnectClusterRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 connect_cluster 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConnectCluster 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation_async 
 . 
 AsyncOperation

    Updates the properties of a single Kafka Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.update_connect_cluster

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.update_connector

      update_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 UpdateConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 connector 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector

    Updates the properties of a connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.update_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient

      ManagedKafkaConnectClient 
 ( 
 * 
 , 
 credentials 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 auth 
 . 
 credentials 
 . 
 Credentials 
 ] 
 = 
 None 
 , 
 transport 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka_connect 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaConnectTransport 
 , 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka_connect 
 . 
 transports 
 . 
 base 
 . 
 ManagedKafkaConnectTransport 
 , 
 ], 
 ] 
 ] 
 = 
 None 
 , 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 client_info 
 : 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 client_info 
 . 
 ClientInfo 
 = 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 client_info 
 . 
 ClientInfo 
 )

    Instantiates the managed kafka connect client.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.__exit__

      __exit__ 
 ( 
 type 
 , 
 value 
 , 
 traceback 
 )

    Releases underlying transport's resources.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient. exit

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.cancel_operation

      cancel_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 CancelOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Starts asynchronous cancellation on a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.cancel_operation 

      common_billing_account_path 
 ( 
 billing_account 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified billing_account string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_billing_account_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_folder_path

      common_folder_path 
 ( 
 folder 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified folder string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_folder_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_location_path

      common_location_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified location string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_location_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_organization_path

      common_organization_path 
 ( 
 organization 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified organization string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_organization_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_project_path

      common_project_path 
 ( 
 project 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified project string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_project_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.connect_cluster_path

      connect_cluster_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 connect_cluster 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified connect_cluster string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.connect_cluster_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.connector_path

      connector_path 
 ( 
 project 
 : 
 str 
 , 
 location 
 : 
 str 
 , 
 connect_cluster 
 : 
 str 
 , 
 connector 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified connector string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.connector_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.create_connect_cluster

      create_connect_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 CreateConnectClusterRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 connect_cluster 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConnectCluster 
 ] 
 = 
 None 
 , 
 connect_cluster_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation 
 . 
 Operation

    Creates a new Kafka Connect cluster in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.create_connect_cluster

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.create_connector

      create_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 CreateConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 connector 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector 
 ] 
 = 
 None 
 , 
 connector_id 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector

    Creates a new connector in a given Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.create_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.delete_connect_cluster

      delete_connect_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 DeleteConnectClusterRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation 
 . 
 Operation

    Deletes a single Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.delete_connect_cluster

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.delete_connector

      delete_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 DeleteConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.delete_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.delete_operation

      delete_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 DeleteOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> None

    Deletes a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.delete_operation 

      from_service_account_file 
 ( 
 filename 
 : 
 str 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials file.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.from_service_account_file 

      from_service_account_info 
 ( 
 info 
 : 
 dict 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials info.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.from_service_account_info 

      from_service_account_json 
 ( 
 filename 
 : 
 str 
 , 
 * 
 args 
 , 
 ** 
 kwargs 
 )

    Creates an instance of this client using the provided credentials file.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.from_service_account_json

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_connect_cluster

      get_connect_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 GetConnectClusterRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConnectCluster

    Returns the properties of a single Kafka Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_connect_cluster

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_connector

      get_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 GetConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector

    Returns the properties of a single connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_location

      get_location 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 GetLocationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 Location

    Gets information about a location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_location

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_mtls_endpoint_and_cert_source

      get_mtls_endpoint_and_cert_source 
 ( 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 , 
 )

    Deprecated.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_mtls_endpoint_and_cert_source

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_operation

      get_operation 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 GetOperationRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 Operation

    Gets the latest state of a long-running operation.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_operation

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.list_connect_clusters

      list_connect_clusters 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectClustersRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> ( 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka_connect 
 . 
 pagers 
 . 
 ListConnectClustersPager 
 )

    Lists the Kafka Connect clusters in a given project and location.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.list_connect_clusters

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.list_connectors

      list_connectors 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectorsRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 parent 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> ( 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 services 
 . 
 managed_kafka_connect 
 . 
 pagers 
 . 
 ListConnectorsPager 
 )

    Lists the connectors in a given Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.list_connectors

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.list_locations

      list_locations 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 ListLocationsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 location 
 . 
 locations_pb2 
 . 
 ListLocationsResponse

    Lists information about the supported locations for this service.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.list_locations

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.list_operations

      list_operations 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 ListOperationsRequest 
 , 
 dict 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 longrunning 
 . 
 operations_pb2 
 . 
 ListOperationsResponse

    Lists operations that match the specified filter in the request.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.list_operations 

      parse_common_billing_account_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a billing_account path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_billing_account_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_folder_path

      parse_common_folder_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a folder path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_folder_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_location_path

      parse_common_location_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a location path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_location_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_organization_path

      parse_common_organization_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a organization path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_organization_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_project_path

      parse_common_project_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parse a project path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_project_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_connect_cluster_path

      parse_connect_cluster_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a connect_cluster path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_connect_cluster_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_connector_path

      parse_connector_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a connector path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_connector_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_secret_version_path

      parse_secret_version_path 
 ( 
 path 
 : 
 str 
 ) 
 - 
> typing 
 . 
 Dict 
 [ 
 str 
 , 
 str 
 ]

    Parses a secret_version path into its component segments.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_secret_version_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.pause_connector

      pause_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 PauseConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 PauseConnectorResponse

    Pauses the connector and its tasks.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.pause_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.restart_connector

      restart_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 RestartConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 RestartConnectorResponse

    Restarts the connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.restart_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.resume_connector

      resume_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ResumeConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ResumeConnectorResponse

    Resumes the connector and its tasks.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.resume_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.secret_version_path

      secret_version_path 
 ( 
 project 
 : 
 str 
 , 
 secret 
 : 
 str 
 , 
 secret_version 
 : 
 str 
 ) 
 - 
> str

    Returns a fully-qualified secret_version string.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.secret_version_path

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.stop_connector

      stop_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 StopConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 name 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 StopConnectorResponse

    Stops the connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.stop_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.update_connect_cluster

      update_connect_cluster 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 UpdateConnectClusterRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 connect_cluster 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 ConnectCluster 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation 
 . 
 Operation

    Updates the properties of a single Kafka Connect cluster.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.update_connect_cluster

    google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.update_connector

      update_connector 
 ( 
 request 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 UpdateConnectorRequest 
 , 
 dict 
 , 
 ] 
 ] 
 = 
 None 
 , 
 * 
 , 
 connector 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector 
 ] 
 = 
 None 
 , 
 update_mask 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 ] 
 = 
 None 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 resources 
 . 
 Connector

    Updates the properties of a connector.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.update_connector

    google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers.ListConnectClustersAsyncPager

      ListConnectClustersAsyncPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 typing 
 . 
 Awaitable 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectClustersResponse 
 ], 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectClustersRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectClustersResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiates the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers.ListConnectClustersAsyncPager

    google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers.ListConnectClustersPager

      ListConnectClustersPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectClustersResponse 
 , 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectClustersRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectClustersResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiate the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers.ListConnectClustersPager

    google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers.ListConnectorsAsyncPager

      ListConnectorsAsyncPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 typing 
 . 
 Awaitable 
 [ 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectorsResponse 
 ], 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectorsRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectorsResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary_async 
 . 
 AsyncRetry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiates the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers.ListConnectorsAsyncPager

    google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers.ListConnectorsPager

      ListConnectorsPager 
 ( 
 method 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 ... 
 ], 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectorsResponse 
 , 
 ], 
 request 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectorsRequest 
 , 
 response 
 : 
 google 
 . 
 cloud 
 . 
 managedkafka_v1 
 . 
 types 
 . 
 managed_kafka_connect 
 . 
 ListConnectorsResponse 
 , 
 * 
 , 
 retry 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 api_core 
 . 
 retry 
 . 
 retry_unary 
 . 
 Retry 
 , 
 google 
 . 
 api_core 
 . 
 gapic_v1 
 . 
 method 
 . 
 _MethodDefault 
 , 
 ] 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 timeout 
 : 
 typing 
 . 
 Union 
 [ 
 float 
 , 
 object 
 ] 
 = 
 _MethodDefault 
 . 
 _DEFAULT_VALUE 
 , 
 metadata 
 : 
 typing 
 . 
 Sequence 
 [ 
 typing 
 . 
 Tuple 
 [ 
 str 
 , 
 typing 
 . 
 Union 
 [ 
 str 
 , 
 bytes 
 ]]] 
 = 
 () 
 )

    Instantiate the pager.

    See more: google.cloud.managedkafka_v1.services.managed_kafka_connect.pagers.ListConnectorsPager

    Design a Mobile Site
    View Site in Mobile | Classic
    Share by: