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

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)

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

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)

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)

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)

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)

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)