Package Methods (0.2.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=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)->strReturns 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.AddAclEntryResponseIncremental 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)->strReturns 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[google.longrunning.operations_pb2.CancelOperationRequest]=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]]]=())->NoneStarts 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)->strReturns a fully-qualified cluster string.
See more:google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.cluster_path
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.common_folder_path
common_folder_path(folder:str)->strReturns 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)->strReturns 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)->strReturns 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)->strReturns 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)->strReturns 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.AclCreates a new acl in the given project, location, andcluster.
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.AsyncOperationCreates a new cluster in a given project andlocation.
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.TopicCreates 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)->strReturns 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]]]=())->NoneDeletes 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.AsyncOperationDeletes 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]]]=())->NoneDeletes 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[google.longrunning.operations_pb2.DeleteOperationRequest]=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]]]=())->NoneDeletes 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]]]=())->NoneDeletes a single topic.
See more:google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.delete_topic
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
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.AclReturns 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.ClusterReturns 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.ConsumerGroupReturns 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[google.cloud.location.locations_pb2.GetLocationRequest]=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.LocationGets 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.
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=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.OperationGets 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.TopicReturns 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.ListAclsAsyncPagerLists 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.ListClustersAsyncPagerLists 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[google.cloud.location.locations_pb2.ListLocationsRequest]=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.ListLocationsResponseLists 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[google.longrunning.operations_pb2.ListOperationsRequest]=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.ListOperationsResponseLists 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.ListTopicsAsyncPagerLists 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
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
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.
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.
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.
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.
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.RemoveAclEntryResponseIncremental 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)->strReturns 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.AclUpdates 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.AsyncOperationUpdates 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.ConsumerGroupUpdates 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.TopicUpdates 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=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)->strReturns 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.AddAclEntryResponseIncremental 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)->strReturns 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[google.longrunning.operations_pb2.CancelOperationRequest]=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]]]=())->NoneStarts 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)->strReturns a fully-qualified cluster string.
See more:google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.cluster_path
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns 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)->strReturns 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)->strReturns 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)->strReturns 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)->strReturns 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)->strReturns 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.AclCreates a new acl in the given project, location, andcluster.
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.OperationCreates a new cluster in a given project andlocation.
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.TopicCreates 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)->strReturns 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]]]=())->NoneDeletes 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.OperationDeletes 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]]]=())->NoneDeletes 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[google.longrunning.operations_pb2.DeleteOperationRequest]=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]]]=())->NoneDeletes 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]]]=())->NoneDeletes a single topic.
See more:google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.delete_topic
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.from_service_account_file
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
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.from_service_account_info
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
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.from_service_account_json
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.AclReturns 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.ClusterReturns 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.ConsumerGroupReturns 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[google.cloud.location.locations_pb2.GetLocationRequest]=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.LocationGets 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.
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=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.OperationGets 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.TopicReturns 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.ListAclsPagerLists 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.ListClustersPagerLists 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.ListConsumerGroupsPagerLists 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[google.cloud.location.locations_pb2.ListLocationsRequest]=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.ListLocationsResponseLists 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[google.longrunning.operations_pb2.ListOperationsRequest]=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.ListOperationsResponseLists 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.ListTopicsPagerLists 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
google.cloud.managedkafka_v1.services.managed_kafka.ManagedKafkaClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
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.
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.RemoveAclEntryResponseIncremental 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)->strReturns 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.AclUpdates 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.OperationUpdates 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.ConsumerGroupUpdates 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.TopicUpdates 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=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[google.longrunning.operations_pb2.CancelOperationRequest]=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]]]=())->NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.connect_cluster_path
connect_cluster_path(project:str,location:str,connect_cluster:str)->strReturns a fully-qualified connect_cluster string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.connector_path
connector_path(project:str,location:str,connect_cluster:str,connector:str)->strReturns a fully-qualified connector string.
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.AsyncOperationCreates a new Kafka Connect cluster in a givenproject and location.
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.ConnectorCreates a new connector in a given Connect cluster.
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.AsyncOperationDeletes a single 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]]]=())->NoneDeletes a connector.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=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]]]=())->NoneDeletes a long-running operation.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
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.ConnectClusterReturns the properties of a single Kafka Connectcluster.
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.ConnectorReturns the properties of a single connector.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_location
get_location(request:typing.Optional[google.cloud.location.locations_pb2.GetLocationRequest]=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.LocationGets information about a 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.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=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.OperationGets the latest state of a long-running 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.
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 projectand location.
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.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_locations
list_locations(request:typing.Optional[google.cloud.location.locations_pb2.ListLocationsRequest]=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.ListLocationsResponseLists information about the supported locations for this service.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.list_operations
list_operations(request:typing.Optional[google.longrunning.operations_pb2.ListOperationsRequest]=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.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
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.
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.
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.
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.
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.
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.
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.
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.PauseConnectorResponsePauses the connector and its tasks.
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.RestartConnectorResponseRestarts the 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.ResumeConnectorResponseResumes the connector and its tasks.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectAsyncClient.secret_version_path
secret_version_path(project:str,secret:str,secret_version:str)->strReturns a fully-qualified secret_version string.
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.StopConnectorResponseStops the 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.AsyncOperationUpdates the properties of a single Kafka Connectcluster.
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.ConnectorUpdates the properties of a 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=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[google.longrunning.operations_pb2.CancelOperationRequest]=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]]]=())->NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_billing_account_path
common_billing_account_path(billing_account:str)->strReturns a fully-qualified billing_account string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_folder_path
common_folder_path(folder:str)->strReturns a fully-qualified folder string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_location_path
common_location_path(project:str,location:str)->strReturns a fully-qualified location string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_organization_path
common_organization_path(organization:str)->strReturns a fully-qualified organization string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.common_project_path
common_project_path(project:str)->strReturns a fully-qualified project string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.connect_cluster_path
connect_cluster_path(project:str,location:str,connect_cluster:str)->strReturns a fully-qualified connect_cluster string.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.connector_path
connector_path(project:str,location:str,connect_cluster:str,connector:str)->strReturns 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.OperationCreates a new Kafka Connect cluster in a givenproject and location.
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.ConnectorCreates a new connector in a given Connect cluster.
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.OperationDeletes a single 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]]]=())->NoneDeletes a connector.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.delete_operation
delete_operation(request:typing.Optional[google.longrunning.operations_pb2.DeleteOperationRequest]=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]]]=())->NoneDeletes a long-running operation.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.from_service_account_file
from_service_account_file(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.from_service_account_info
from_service_account_info(info:dict,*args,**kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.from_service_account_json
from_service_account_json(filename:str,*args,**kwargs)Creates an instance of this client using the provided credentials file.
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.ConnectClusterReturns the properties of a single Kafka Connectcluster.
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.ConnectorReturns 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[google.cloud.location.locations_pb2.GetLocationRequest]=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.LocationGets 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.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.get_operation
get_operation(request:typing.Optional[google.longrunning.operations_pb2.GetOperationRequest]=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.OperationGets 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 projectand location.
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.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.list_locations
list_locations(request:typing.Optional[google.cloud.location.locations_pb2.ListLocationsRequest]=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.ListLocationsResponseLists 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[google.longrunning.operations_pb2.ListOperationsRequest]=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.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.parse_common_billing_account_path
parse_common_billing_account_path(path:str)->typing.Dict[str,str]Parse a billing_account path into its component segments.
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.
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.
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.
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.
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.
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.
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.
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.PauseConnectorResponsePauses the connector and its tasks.
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.RestartConnectorResponseRestarts the 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.ResumeConnectorResponseResumes the connector and its tasks.
google.cloud.managedkafka_v1.services.managed_kafka_connect.ManagedKafkaConnectClient.secret_version_path
secret_version_path(project:str,secret:str,secret_version:str)->strReturns a fully-qualified secret_version string.
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.StopConnectorResponseStops 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.OperationUpdates the properties of a single Kafka Connectcluster.
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.ConnectorUpdates the properties of a 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
Except as otherwise noted, the content of this page is licensed under theCreative Commons Attribution 4.0 License, and code samples are licensed under theApache 2.0 License. For details, see theGoogle Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-10-30 UTC.