Managed Service for Apache Kafka API v1 API - Class ManagedKafkaClientImpl (1.0.0-beta07)

Version latest

• 1.0.0-beta07 (latest)
• 1.0.0-beta06

public sealed class ManagedKafkaClientImpl : ManagedKafkaClient

Reference documentation and code samples for the Managed Service for Apache Kafka API v1 API class ManagedKafkaClientImpl.

ManagedKafka client wrapper implementation, for convenient use.

Inheritance

object > ManagedKafkaClient > ManagedKafkaClientImpl

Inherited Members

ManagedKafkaClient.DefaultEndpoint

ManagedKafkaClient.DefaultScopes

ManagedKafkaClient.ServiceMetadata

ManagedKafkaClient.CreateAsync(CancellationToken)

ManagedKafkaClient.Create()

ManagedKafkaClient.ShutdownDefaultChannelsAsync()

ManagedKafkaClient.ListClusters(string, string, int?, CallSettings)

ManagedKafkaClient.ListClustersAsync(string, string, int?, CallSettings)

ManagedKafkaClient.ListClusters(LocationName, string, int?, CallSettings)

ManagedKafkaClient.ListClustersAsync(LocationName, string, int?, CallSettings)

ManagedKafkaClient.GetClusterAsync(GetClusterRequest, CancellationToken)

ManagedKafkaClient.GetCluster(string, CallSettings)

ManagedKafkaClient.GetClusterAsync(string, CallSettings)

ManagedKafkaClient.GetClusterAsync(string, CancellationToken)

ManagedKafkaClient.GetCluster(ClusterName, CallSettings)

ManagedKafkaClient.GetClusterAsync(ClusterName, CallSettings)

ManagedKafkaClient.GetClusterAsync(ClusterName, CancellationToken)

ManagedKafkaClient.CreateClusterAsync(CreateClusterRequest, CancellationToken)

ManagedKafkaClient.PollOnceCreateCluster(string, CallSettings)

ManagedKafkaClient.PollOnceCreateClusterAsync(string, CallSettings)

ManagedKafkaClient.CreateCluster(string, Cluster, string, CallSettings)

ManagedKafkaClient.CreateClusterAsync(string, Cluster, string, CallSettings)

ManagedKafkaClient.CreateClusterAsync(string, Cluster, string, CancellationToken)

ManagedKafkaClient.CreateCluster(LocationName, Cluster, string, CallSettings)

ManagedKafkaClient.CreateClusterAsync(LocationName, Cluster, string, CallSettings)

ManagedKafkaClient.CreateClusterAsync(LocationName, Cluster, string, CancellationToken)

ManagedKafkaClient.UpdateClusterAsync(UpdateClusterRequest, CancellationToken)

ManagedKafkaClient.PollOnceUpdateCluster(string, CallSettings)

ManagedKafkaClient.PollOnceUpdateClusterAsync(string, CallSettings)

ManagedKafkaClient.UpdateCluster(Cluster, FieldMask, CallSettings)

ManagedKafkaClient.UpdateClusterAsync(Cluster, FieldMask, CallSettings)

ManagedKafkaClient.UpdateClusterAsync(Cluster, FieldMask, CancellationToken)

ManagedKafkaClient.DeleteClusterAsync(DeleteClusterRequest, CancellationToken)

ManagedKafkaClient.PollOnceDeleteCluster(string, CallSettings)

ManagedKafkaClient.PollOnceDeleteClusterAsync(string, CallSettings)

ManagedKafkaClient.DeleteCluster(string, CallSettings)

ManagedKafkaClient.DeleteClusterAsync(string, CallSettings)

ManagedKafkaClient.DeleteClusterAsync(string, CancellationToken)

ManagedKafkaClient.DeleteCluster(ClusterName, CallSettings)

ManagedKafkaClient.DeleteClusterAsync(ClusterName, CallSettings)

ManagedKafkaClient.DeleteClusterAsync(ClusterName, CancellationToken)

ManagedKafkaClient.ListTopics(string, string, int?, CallSettings)

ManagedKafkaClient.ListTopicsAsync(string, string, int?, CallSettings)

ManagedKafkaClient.ListTopics(ClusterName, string, int?, CallSettings)

ManagedKafkaClient.ListTopicsAsync(ClusterName, string, int?, CallSettings)

ManagedKafkaClient.GetTopicAsync(GetTopicRequest, CancellationToken)

ManagedKafkaClient.GetTopic(string, CallSettings)

ManagedKafkaClient.GetTopicAsync(string, CallSettings)

ManagedKafkaClient.GetTopicAsync(string, CancellationToken)

ManagedKafkaClient.GetTopic(TopicName, CallSettings)

ManagedKafkaClient.GetTopicAsync(TopicName, CallSettings)

ManagedKafkaClient.GetTopicAsync(TopicName, CancellationToken)

ManagedKafkaClient.CreateTopicAsync(CreateTopicRequest, CancellationToken)

ManagedKafkaClient.CreateTopic(string, Topic, string, CallSettings)

ManagedKafkaClient.CreateTopicAsync(string, Topic, string, CallSettings)

ManagedKafkaClient.CreateTopicAsync(string, Topic, string, CancellationToken)

ManagedKafkaClient.CreateTopic(ClusterName, Topic, string, CallSettings)

ManagedKafkaClient.CreateTopicAsync(ClusterName, Topic, string, CallSettings)

ManagedKafkaClient.CreateTopicAsync(ClusterName, Topic, string, CancellationToken)

ManagedKafkaClient.UpdateTopicAsync(UpdateTopicRequest, CancellationToken)

ManagedKafkaClient.UpdateTopic(Topic, FieldMask, CallSettings)

ManagedKafkaClient.UpdateTopicAsync(Topic, FieldMask, CallSettings)

ManagedKafkaClient.UpdateTopicAsync(Topic, FieldMask, CancellationToken)

ManagedKafkaClient.DeleteTopicAsync(DeleteTopicRequest, CancellationToken)

ManagedKafkaClient.DeleteTopic(string, CallSettings)

ManagedKafkaClient.DeleteTopicAsync(string, CallSettings)

ManagedKafkaClient.DeleteTopicAsync(string, CancellationToken)

ManagedKafkaClient.DeleteTopic(TopicName, CallSettings)

ManagedKafkaClient.DeleteTopicAsync(TopicName, CallSettings)

ManagedKafkaClient.DeleteTopicAsync(TopicName, CancellationToken)

ManagedKafkaClient.ListConsumerGroups(string, string, int?, CallSettings)

ManagedKafkaClient.ListConsumerGroupsAsync(string, string, int?, CallSettings)

ManagedKafkaClient.ListConsumerGroups(ClusterName, string, int?, CallSettings)

ManagedKafkaClient.ListConsumerGroupsAsync(ClusterName, string, int?, CallSettings)

ManagedKafkaClient.GetConsumerGroupAsync(GetConsumerGroupRequest, CancellationToken)

ManagedKafkaClient.GetConsumerGroup(string, CallSettings)

ManagedKafkaClient.GetConsumerGroupAsync(string, CallSettings)

ManagedKafkaClient.GetConsumerGroupAsync(string, CancellationToken)

ManagedKafkaClient.GetConsumerGroup(ConsumerGroupName, CallSettings)

ManagedKafkaClient.GetConsumerGroupAsync(ConsumerGroupName, CallSettings)

ManagedKafkaClient.GetConsumerGroupAsync(ConsumerGroupName, CancellationToken)

ManagedKafkaClient.UpdateConsumerGroupAsync(UpdateConsumerGroupRequest, CancellationToken)

ManagedKafkaClient.UpdateConsumerGroup(ConsumerGroup, FieldMask, CallSettings)

ManagedKafkaClient.UpdateConsumerGroupAsync(ConsumerGroup, FieldMask, CallSettings)

ManagedKafkaClient.UpdateConsumerGroupAsync(ConsumerGroup, FieldMask, CancellationToken)

ManagedKafkaClient.DeleteConsumerGroupAsync(DeleteConsumerGroupRequest, CancellationToken)

ManagedKafkaClient.DeleteConsumerGroup(string, CallSettings)

ManagedKafkaClient.DeleteConsumerGroupAsync(string, CallSettings)

ManagedKafkaClient.DeleteConsumerGroupAsync(string, CancellationToken)

ManagedKafkaClient.DeleteConsumerGroup(ConsumerGroupName, CallSettings)

ManagedKafkaClient.DeleteConsumerGroupAsync(ConsumerGroupName, CallSettings)

ManagedKafkaClient.DeleteConsumerGroupAsync(ConsumerGroupName, CancellationToken)

ManagedKafkaClient.ListAcls(string, string, int?, CallSettings)

ManagedKafkaClient.ListAclsAsync(string, string, int?, CallSettings)

ManagedKafkaClient.ListAcls(ClusterName, string, int?, CallSettings)

ManagedKafkaClient.ListAclsAsync(ClusterName, string, int?, CallSettings)

ManagedKafkaClient.GetAclAsync(GetAclRequest, CancellationToken)

ManagedKafkaClient.GetAcl(string, CallSettings)

ManagedKafkaClient.GetAclAsync(string, CallSettings)

ManagedKafkaClient.GetAclAsync(string, CancellationToken)

ManagedKafkaClient.GetAcl(AclName, CallSettings)

ManagedKafkaClient.GetAclAsync(AclName, CallSettings)

ManagedKafkaClient.GetAclAsync(AclName, CancellationToken)

ManagedKafkaClient.CreateAclAsync(CreateAclRequest, CancellationToken)

ManagedKafkaClient.CreateAcl(string, Acl, string, CallSettings)

ManagedKafkaClient.CreateAclAsync(string, Acl, string, CallSettings)

ManagedKafkaClient.CreateAclAsync(string, Acl, string, CancellationToken)

ManagedKafkaClient.CreateAcl(ClusterName, Acl, string, CallSettings)

ManagedKafkaClient.CreateAclAsync(ClusterName, Acl, string, CallSettings)

ManagedKafkaClient.CreateAclAsync(ClusterName, Acl, string, CancellationToken)

ManagedKafkaClient.UpdateAclAsync(UpdateAclRequest, CancellationToken)

ManagedKafkaClient.UpdateAcl(Acl, FieldMask, CallSettings)

ManagedKafkaClient.UpdateAclAsync(Acl, FieldMask, CallSettings)

ManagedKafkaClient.UpdateAclAsync(Acl, FieldMask, CancellationToken)

ManagedKafkaClient.DeleteAclAsync(DeleteAclRequest, CancellationToken)

ManagedKafkaClient.DeleteAcl(string, CallSettings)

ManagedKafkaClient.DeleteAclAsync(string, CallSettings)

ManagedKafkaClient.DeleteAclAsync(string, CancellationToken)

ManagedKafkaClient.DeleteAcl(AclName, CallSettings)

ManagedKafkaClient.DeleteAclAsync(AclName, CallSettings)

ManagedKafkaClient.DeleteAclAsync(AclName, CancellationToken)

ManagedKafkaClient.AddAclEntryAsync(AddAclEntryRequest, CancellationToken)

ManagedKafkaClient.AddAclEntry(string, AclEntry, CallSettings)

ManagedKafkaClient.AddAclEntryAsync(string, AclEntry, CallSettings)

ManagedKafkaClient.AddAclEntryAsync(string, AclEntry, CancellationToken)

ManagedKafkaClient.AddAclEntry(AclName, AclEntry, CallSettings)

ManagedKafkaClient.AddAclEntryAsync(AclName, AclEntry, CallSettings)

ManagedKafkaClient.AddAclEntryAsync(AclName, AclEntry, CancellationToken)

ManagedKafkaClient.RemoveAclEntryAsync(RemoveAclEntryRequest, CancellationToken)

ManagedKafkaClient.RemoveAclEntry(string, AclEntry, CallSettings)

ManagedKafkaClient.RemoveAclEntryAsync(string, AclEntry, CallSettings)

ManagedKafkaClient.RemoveAclEntryAsync(string, AclEntry, CancellationToken)

ManagedKafkaClient.RemoveAclEntry(AclName, AclEntry, CallSettings)

ManagedKafkaClient.RemoveAclEntryAsync(AclName, AclEntry, CallSettings)

ManagedKafkaClient.RemoveAclEntryAsync(AclName, AclEntry, CancellationToken)

object.GetHashCode()

object.GetType()

object.ToString()

Namespace

Google.Cloud.ManagedKafka.V1

Assembly

Google.Cloud.ManagedKafka.V1.dll

Remarks

The service that a client application uses to manage Apache Kafka clusters, topics and consumer groups.

Constructors

ManagedKafkaClientImpl(ManagedKafkaClient, ManagedKafkaSettings, ILogger)

public ManagedKafkaClientImpl(ManagedKafka.ManagedKafkaClient grpcClient, ManagedKafkaSettings settings, ILogger logger)

Constructs a client wrapper for the ManagedKafka service, with the specified gRPC client and settings.

Parameters
Name	Description
grpcClient	ManagedKafkaManagedKafkaClient The underlying gRPC client.
settings	ManagedKafkaSettings The base ManagedKafkaSettings used within this client.
logger	ILogger Optional ILogger to use within this client.

Properties

CreateClusterOperationsClient

public override OperationsClient CreateClusterOperationsClient { get; }

The long-running operations client for CreateCluster.

Property Value
Type	Description
OperationsClient

Overrides

ManagedKafkaClient.CreateClusterOperationsClient

DeleteClusterOperationsClient

public override OperationsClient DeleteClusterOperationsClient { get; }

The long-running operations client for DeleteCluster.

Property Value
Type	Description
OperationsClient

Overrides

ManagedKafkaClient.DeleteClusterOperationsClient

GrpcClient

public override ManagedKafka.ManagedKafkaClient GrpcClient { get; }

The underlying gRPC ManagedKafka client

Property Value
Type	Description
ManagedKafkaManagedKafkaClient

Overrides

ManagedKafkaClient.GrpcClient

LocationsClient

public override LocationsClient LocationsClient { get; }

The LocationsClient associated with this client.

Property Value
Type	Description
LocationsClient

Overrides

ManagedKafkaClient.LocationsClient

UpdateClusterOperationsClient

public override OperationsClient UpdateClusterOperationsClient { get; }

The long-running operations client for UpdateCluster.

Property Value
Type	Description
OperationsClient

Overrides

ManagedKafkaClient.UpdateClusterOperationsClient

Methods

AddAclEntry(AddAclEntryRequest, CallSettings)

public override AddAclEntryResponse AddAclEntry(AddAclEntryRequest request, CallSettings callSettings = null)

Incremental update: Adds an acl entry to an acl. Creates the acl if it does not exist yet.

Parameters
Name	Description
request	AddAclEntryRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
AddAclEntryResponse	The RPC response.

Overrides

ManagedKafkaClient.AddAclEntry(AddAclEntryRequest, CallSettings)

AddAclEntryAsync(AddAclEntryRequest, CallSettings)

public override Task<AddAclEntryResponse> AddAclEntryAsync(AddAclEntryRequest request, CallSettings callSettings = null)

Incremental update: Adds an acl entry to an acl. Creates the acl if it does not exist yet.

Parameters
Name	Description
request	AddAclEntryRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskAddAclEntryResponse	A Task containing the RPC response.

Overrides

ManagedKafkaClient.AddAclEntryAsync(AddAclEntryRequest, CallSettings)

CreateAcl(CreateAclRequest, CallSettings)

public override Acl CreateAcl(CreateAclRequest request, CallSettings callSettings = null)

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

Parameters
Name	Description
request	CreateAclRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Acl	The RPC response.

Overrides

ManagedKafkaClient.CreateAcl(CreateAclRequest, CallSettings)

CreateAclAsync(CreateAclRequest, CallSettings)

public override Task<Acl> CreateAclAsync(CreateAclRequest request, CallSettings callSettings = null)

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

Parameters
Name	Description
request	CreateAclRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskAcl	A Task containing the RPC response.

Overrides

ManagedKafkaClient.CreateAclAsync(CreateAclRequest, CallSettings)

CreateCluster(CreateClusterRequest, CallSettings)

public override Operation<Cluster, OperationMetadata> CreateCluster(CreateClusterRequest request, CallSettings callSettings = null)

Creates a new cluster in a given project and location.

Parameters
Name	Description
request	CreateClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationClusterOperationMetadata	The RPC response.

Overrides

ManagedKafkaClient.CreateCluster(CreateClusterRequest, CallSettings)

CreateClusterAsync(CreateClusterRequest, CallSettings)

public override Task<Operation<Cluster, OperationMetadata>> CreateClusterAsync(CreateClusterRequest request, CallSettings callSettings = null)

Creates a new cluster in a given project and location.

Parameters
Name	Description
request	CreateClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Overrides

ManagedKafkaClient.CreateClusterAsync(CreateClusterRequest, CallSettings)

CreateTopic(CreateTopicRequest, CallSettings)

public override Topic CreateTopic(CreateTopicRequest request, CallSettings callSettings = null)

Creates a new topic in a given project and location.

Parameters
Name	Description
request	CreateTopicRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Topic	The RPC response.

Overrides

ManagedKafkaClient.CreateTopic(CreateTopicRequest, CallSettings)

CreateTopicAsync(CreateTopicRequest, CallSettings)

public override Task<Topic> CreateTopicAsync(CreateTopicRequest request, CallSettings callSettings = null)

Creates a new topic in a given project and location.

Parameters
Name	Description
request	CreateTopicRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskTopic	A Task containing the RPC response.

Overrides

ManagedKafkaClient.CreateTopicAsync(CreateTopicRequest, CallSettings)

DeleteAcl(DeleteAclRequest, CallSettings)

public override void DeleteAcl(DeleteAclRequest request, CallSettings callSettings = null)

Deletes an acl.

Parameters
Name	Description
request	DeleteAclRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Overrides

ManagedKafkaClient.DeleteAcl(DeleteAclRequest, CallSettings)

DeleteAclAsync(DeleteAclRequest, CallSettings)

public override Task DeleteAclAsync(DeleteAclRequest request, CallSettings callSettings = null)

Deletes an acl.

Parameters
Name	Description
request	DeleteAclRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Task	A Task containing the RPC response.

Overrides

ManagedKafkaClient.DeleteAclAsync(DeleteAclRequest, CallSettings)

DeleteCluster(DeleteClusterRequest, CallSettings)

public override Operation<Empty, OperationMetadata> DeleteCluster(DeleteClusterRequest request, CallSettings callSettings = null)

Deletes a single cluster.

Parameters
Name	Description
request	DeleteClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationEmptyOperationMetadata	The RPC response.

Overrides

ManagedKafkaClient.DeleteCluster(DeleteClusterRequest, CallSettings)

DeleteClusterAsync(DeleteClusterRequest, CallSettings)

public override Task<Operation<Empty, OperationMetadata>> DeleteClusterAsync(DeleteClusterRequest request, CallSettings callSettings = null)

Deletes a single cluster.

Parameters
Name	Description
request	DeleteClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationEmptyOperationMetadata	A Task containing the RPC response.

Overrides

ManagedKafkaClient.DeleteClusterAsync(DeleteClusterRequest, CallSettings)

DeleteConsumerGroup(DeleteConsumerGroupRequest, CallSettings)

public override void DeleteConsumerGroup(DeleteConsumerGroupRequest request, CallSettings callSettings = null)

Deletes a single consumer group.

Parameters
Name	Description
request	DeleteConsumerGroupRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Overrides

ManagedKafkaClient.DeleteConsumerGroup(DeleteConsumerGroupRequest, CallSettings)

DeleteConsumerGroupAsync(DeleteConsumerGroupRequest, CallSettings)

public override Task DeleteConsumerGroupAsync(DeleteConsumerGroupRequest request, CallSettings callSettings = null)

Deletes a single consumer group.

Parameters
Name	Description
request	DeleteConsumerGroupRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Task	A Task containing the RPC response.

Overrides

ManagedKafkaClient.DeleteConsumerGroupAsync(DeleteConsumerGroupRequest, CallSettings)

DeleteTopic(DeleteTopicRequest, CallSettings)

public override void DeleteTopic(DeleteTopicRequest request, CallSettings callSettings = null)

Deletes a single topic.

Parameters
Name	Description
request	DeleteTopicRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Overrides

ManagedKafkaClient.DeleteTopic(DeleteTopicRequest, CallSettings)

DeleteTopicAsync(DeleteTopicRequest, CallSettings)

public override Task DeleteTopicAsync(DeleteTopicRequest request, CallSettings callSettings = null)

Deletes a single topic.

Parameters
Name	Description
request	DeleteTopicRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Task	A Task containing the RPC response.

Overrides

ManagedKafkaClient.DeleteTopicAsync(DeleteTopicRequest, CallSettings)

GetAcl(GetAclRequest, CallSettings)

public override Acl GetAcl(GetAclRequest request, CallSettings callSettings = null)

Returns the properties of a single acl.

Parameters
Name	Description
request	GetAclRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Acl	The RPC response.

Overrides

ManagedKafkaClient.GetAcl(GetAclRequest, CallSettings)

GetAclAsync(GetAclRequest, CallSettings)

public override Task<Acl> GetAclAsync(GetAclRequest request, CallSettings callSettings = null)

Returns the properties of a single acl.

Parameters
Name	Description
request	GetAclRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskAcl	A Task containing the RPC response.

Overrides

ManagedKafkaClient.GetAclAsync(GetAclRequest, CallSettings)

GetCluster(GetClusterRequest, CallSettings)

public override Cluster GetCluster(GetClusterRequest request, CallSettings callSettings = null)

Returns the properties of a single cluster.

Parameters
Name	Description
request	GetClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Cluster	The RPC response.

Overrides

ManagedKafkaClient.GetCluster(GetClusterRequest, CallSettings)

GetClusterAsync(GetClusterRequest, CallSettings)

public override Task<Cluster> GetClusterAsync(GetClusterRequest request, CallSettings callSettings = null)

Returns the properties of a single cluster.

Parameters
Name	Description
request	GetClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskCluster	A Task containing the RPC response.

Overrides

ManagedKafkaClient.GetClusterAsync(GetClusterRequest, CallSettings)

GetConsumerGroup(GetConsumerGroupRequest, CallSettings)

public override ConsumerGroup GetConsumerGroup(GetConsumerGroupRequest request, CallSettings callSettings = null)

Returns the properties of a single consumer group.

Parameters
Name	Description
request	GetConsumerGroupRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
ConsumerGroup	The RPC response.

Overrides

ManagedKafkaClient.GetConsumerGroup(GetConsumerGroupRequest, CallSettings)

GetConsumerGroupAsync(GetConsumerGroupRequest, CallSettings)

public override Task<ConsumerGroup> GetConsumerGroupAsync(GetConsumerGroupRequest request, CallSettings callSettings = null)

Returns the properties of a single consumer group.

Parameters
Name	Description
request	GetConsumerGroupRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskConsumerGroup	A Task containing the RPC response.

Overrides

ManagedKafkaClient.GetConsumerGroupAsync(GetConsumerGroupRequest, CallSettings)

GetTopic(GetTopicRequest, CallSettings)

public override Topic GetTopic(GetTopicRequest request, CallSettings callSettings = null)

Returns the properties of a single topic.

Parameters
Name	Description
request	GetTopicRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Topic	The RPC response.

Overrides

ManagedKafkaClient.GetTopic(GetTopicRequest, CallSettings)

GetTopicAsync(GetTopicRequest, CallSettings)

public override Task<Topic> GetTopicAsync(GetTopicRequest request, CallSettings callSettings = null)

Returns the properties of a single topic.

Parameters
Name	Description
request	GetTopicRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskTopic	A Task containing the RPC response.

Overrides

ManagedKafkaClient.GetTopicAsync(GetTopicRequest, CallSettings)

ListAcls(ListAclsRequest, CallSettings)

public override PagedEnumerable<ListAclsResponse, Acl> ListAcls(ListAclsRequest request, CallSettings callSettings = null)

Lists the acls in a given cluster.

Parameters
Name	Description
request	ListAclsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListAclsResponseAcl	A pageable sequence of Acl resources.

Overrides

ManagedKafkaClient.ListAcls(ListAclsRequest, CallSettings)

ListAclsAsync(ListAclsRequest, CallSettings)

public override PagedAsyncEnumerable<ListAclsResponse, Acl> ListAclsAsync(ListAclsRequest request, CallSettings callSettings = null)

Lists the acls in a given cluster.

Parameters
Name	Description
request	ListAclsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListAclsResponseAcl	A pageable asynchronous sequence of Acl resources.

Overrides

ManagedKafkaClient.ListAclsAsync(ListAclsRequest, CallSettings)

ListClusters(ListClustersRequest, CallSettings)

public override PagedEnumerable<ListClustersResponse, Cluster> ListClusters(ListClustersRequest request, CallSettings callSettings = null)

Lists the clusters in a given project and location.

Parameters
Name	Description
request	ListClustersRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListClustersResponseCluster	A pageable sequence of Cluster resources.

Overrides

ManagedKafkaClient.ListClusters(ListClustersRequest, CallSettings)

ListClustersAsync(ListClustersRequest, CallSettings)

public override PagedAsyncEnumerable<ListClustersResponse, Cluster> ListClustersAsync(ListClustersRequest request, CallSettings callSettings = null)

Lists the clusters in a given project and location.

Parameters
Name	Description
request	ListClustersRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListClustersResponseCluster	A pageable asynchronous sequence of Cluster resources.

Overrides

ManagedKafkaClient.ListClustersAsync(ListClustersRequest, CallSettings)

ListConsumerGroups(ListConsumerGroupsRequest, CallSettings)

public override PagedEnumerable<ListConsumerGroupsResponse, ConsumerGroup> ListConsumerGroups(ListConsumerGroupsRequest request, CallSettings callSettings = null)

Lists the consumer groups in a given cluster.

Parameters
Name	Description
request	ListConsumerGroupsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListConsumerGroupsResponseConsumerGroup	A pageable sequence of ConsumerGroup resources.

Overrides

ManagedKafkaClient.ListConsumerGroups(ListConsumerGroupsRequest, CallSettings)

ListConsumerGroupsAsync(ListConsumerGroupsRequest, CallSettings)

public override PagedAsyncEnumerable<ListConsumerGroupsResponse, ConsumerGroup> ListConsumerGroupsAsync(ListConsumerGroupsRequest request, CallSettings callSettings = null)

Lists the consumer groups in a given cluster.

Parameters
Name	Description
request	ListConsumerGroupsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListConsumerGroupsResponseConsumerGroup	A pageable asynchronous sequence of ConsumerGroup resources.

Overrides

ManagedKafkaClient.ListConsumerGroupsAsync(ListConsumerGroupsRequest, CallSettings)

ListTopics(ListTopicsRequest, CallSettings)

public override PagedEnumerable<ListTopicsResponse, Topic> ListTopics(ListTopicsRequest request, CallSettings callSettings = null)

Lists the topics in a given cluster.

Parameters
Name	Description
request	ListTopicsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedEnumerableListTopicsResponseTopic	A pageable sequence of Topic resources.

Overrides

ManagedKafkaClient.ListTopics(ListTopicsRequest, CallSettings)

ListTopicsAsync(ListTopicsRequest, CallSettings)

public override PagedAsyncEnumerable<ListTopicsResponse, Topic> ListTopicsAsync(ListTopicsRequest request, CallSettings callSettings = null)

Lists the topics in a given cluster.

Parameters
Name	Description
request	ListTopicsRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
PagedAsyncEnumerableListTopicsResponseTopic	A pageable asynchronous sequence of Topic resources.

Overrides

ManagedKafkaClient.ListTopicsAsync(ListTopicsRequest, CallSettings)

RemoveAclEntry(RemoveAclEntryRequest, CallSettings)

public override RemoveAclEntryResponse RemoveAclEntry(RemoveAclEntryRequest request, CallSettings callSettings = null)

Incremental update: Removes an acl entry from an acl. Deletes the acl if its acl entries become empty (i.e. if the removed entry was the last one in the acl).

Parameters
Name	Description
request	RemoveAclEntryRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
RemoveAclEntryResponse	The RPC response.

Overrides

ManagedKafkaClient.RemoveAclEntry(RemoveAclEntryRequest, CallSettings)

RemoveAclEntryAsync(RemoveAclEntryRequest, CallSettings)

public override Task<RemoveAclEntryResponse> RemoveAclEntryAsync(RemoveAclEntryRequest request, CallSettings callSettings = null)

Incremental update: Removes an acl entry from an acl. Deletes the acl if its acl entries become empty (i.e. if the removed entry was the last one in the acl).

Parameters
Name	Description
request	RemoveAclEntryRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskRemoveAclEntryResponse	A Task containing the RPC response.

Overrides

ManagedKafkaClient.RemoveAclEntryAsync(RemoveAclEntryRequest, CallSettings)

UpdateAcl(UpdateAclRequest, CallSettings)

public override Acl UpdateAcl(UpdateAclRequest request, CallSettings callSettings = null)

Updates the properties of a single acl.

Parameters
Name	Description
request	UpdateAclRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Acl	The RPC response.

Overrides

ManagedKafkaClient.UpdateAcl(UpdateAclRequest, CallSettings)

UpdateAclAsync(UpdateAclRequest, CallSettings)

public override Task<Acl> UpdateAclAsync(UpdateAclRequest request, CallSettings callSettings = null)

Updates the properties of a single acl.

Parameters
Name	Description
request	UpdateAclRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskAcl	A Task containing the RPC response.

Overrides

ManagedKafkaClient.UpdateAclAsync(UpdateAclRequest, CallSettings)

UpdateCluster(UpdateClusterRequest, CallSettings)

public override Operation<Cluster, OperationMetadata> UpdateCluster(UpdateClusterRequest request, CallSettings callSettings = null)

Updates the properties of a single cluster.

Parameters
Name	Description
request	UpdateClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
OperationClusterOperationMetadata	The RPC response.

Overrides

ManagedKafkaClient.UpdateCluster(UpdateClusterRequest, CallSettings)

UpdateClusterAsync(UpdateClusterRequest, CallSettings)

public override Task<Operation<Cluster, OperationMetadata>> UpdateClusterAsync(UpdateClusterRequest request, CallSettings callSettings = null)

Updates the properties of a single cluster.

Parameters
Name	Description
request	UpdateClusterRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskOperationClusterOperationMetadata	A Task containing the RPC response.

Overrides

ManagedKafkaClient.UpdateClusterAsync(UpdateClusterRequest, CallSettings)

UpdateConsumerGroup(UpdateConsumerGroupRequest, CallSettings)

public override ConsumerGroup UpdateConsumerGroup(UpdateConsumerGroupRequest request, CallSettings callSettings = null)

Updates the properties of a single consumer group.

Parameters
Name	Description
request	UpdateConsumerGroupRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
ConsumerGroup	The RPC response.

Overrides

ManagedKafkaClient.UpdateConsumerGroup(UpdateConsumerGroupRequest, CallSettings)

UpdateConsumerGroupAsync(UpdateConsumerGroupRequest, CallSettings)

public override Task<ConsumerGroup> UpdateConsumerGroupAsync(UpdateConsumerGroupRequest request, CallSettings callSettings = null)

Updates the properties of a single consumer group.

Parameters
Name	Description
request	UpdateConsumerGroupRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskConsumerGroup	A Task containing the RPC response.

Overrides

ManagedKafkaClient.UpdateConsumerGroupAsync(UpdateConsumerGroupRequest, CallSettings)

UpdateTopic(UpdateTopicRequest, CallSettings)

public override Topic UpdateTopic(UpdateTopicRequest request, CallSettings callSettings = null)

Updates the properties of a single topic.

Parameters
Name	Description
request	UpdateTopicRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
Topic	The RPC response.

Overrides

ManagedKafkaClient.UpdateTopic(UpdateTopicRequest, CallSettings)

UpdateTopicAsync(UpdateTopicRequest, CallSettings)

public override Task<Topic> UpdateTopicAsync(UpdateTopicRequest request, CallSettings callSettings = null)

Updates the properties of a single topic.

Parameters
Name	Description
request	UpdateTopicRequest The request object containing all of the parameters for the API call.
callSettings	CallSettings If not null, applies overrides to this RPC call.

Returns
Type	Description
TaskTopic	A Task containing the RPC response.

Overrides

ManagedKafkaClient.UpdateTopicAsync(UpdateTopicRequest, CallSettings)