Class ManagedKafkaGrpc.ManagedKafkaBlockingStub (0.2.0)

public static final class ManagedKafkaGrpc.ManagedKafkaBlockingStub extends AbstractBlockingStub<ManagedKafkaGrpc.ManagedKafkaBlockingStub>

A stub to allow clients to do synchronous rpc calls to service ManagedKafka.

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

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractBlockingStub > ManagedKafkaGrpc.ManagedKafkaBlockingStub

Methods

build(Channel channel, CallOptions callOptions)

protected ManagedKafkaGrpc.ManagedKafkaBlockingStub build(Channel channel, CallOptions callOptions)
Parameters
Name Description
channel io.grpc.Channel
callOptions io.grpc.CallOptions
Returns
Type Description
ManagedKafkaGrpc.ManagedKafkaBlockingStub
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

createCluster(CreateClusterRequest request)

public Operation createCluster(CreateClusterRequest request)

Creates a new cluster in a given project and location.

Parameter
Name Description
request CreateClusterRequest
Returns
Type Description
Operation

createTopic(CreateTopicRequest request)

public Topic createTopic(CreateTopicRequest request)

Creates a new topic in a given project and location.

Parameter
Name Description
request CreateTopicRequest
Returns
Type Description
Topic

deleteCluster(DeleteClusterRequest request)

public Operation deleteCluster(DeleteClusterRequest request)

Deletes a single cluster.

Parameter
Name Description
request DeleteClusterRequest
Returns
Type Description
Operation

deleteConsumerGroup(DeleteConsumerGroupRequest request)

public Empty deleteConsumerGroup(DeleteConsumerGroupRequest request)

Deletes a single consumer group.

Parameter
Name Description
request DeleteConsumerGroupRequest
Returns
Type Description
Empty

deleteTopic(DeleteTopicRequest request)

public Empty deleteTopic(DeleteTopicRequest request)

Deletes a single topic.

Parameter
Name Description
request DeleteTopicRequest
Returns
Type Description
Empty

getCluster(GetClusterRequest request)

public Cluster getCluster(GetClusterRequest request)

Returns the properties of a single cluster.

Parameter
Name Description
request GetClusterRequest
Returns
Type Description
Cluster

getConsumerGroup(GetConsumerGroupRequest request)

public ConsumerGroup getConsumerGroup(GetConsumerGroupRequest request)

Returns the properties of a single consumer group.

Parameter
Name Description
request GetConsumerGroupRequest
Returns
Type Description
ConsumerGroup

getTopic(GetTopicRequest request)

public Topic getTopic(GetTopicRequest request)

Returns the properties of a single topic.

Parameter
Name Description
request GetTopicRequest
Returns
Type Description
Topic

listClusters(ListClustersRequest request)

public ListClustersResponse listClusters(ListClustersRequest request)

Lists the clusters in a given project and location.

Parameter
Name Description
request ListClustersRequest
Returns
Type Description
ListClustersResponse

listConsumerGroups(ListConsumerGroupsRequest request)

public ListConsumerGroupsResponse listConsumerGroups(ListConsumerGroupsRequest request)

Lists the consumer groups in a given cluster.

Parameter
Name Description
request ListConsumerGroupsRequest
Returns
Type Description
ListConsumerGroupsResponse

listTopics(ListTopicsRequest request)

public ListTopicsResponse listTopics(ListTopicsRequest request)

Lists the topics in a given cluster.

Parameter
Name Description
request ListTopicsRequest
Returns
Type Description
ListTopicsResponse

updateCluster(UpdateClusterRequest request)

public Operation updateCluster(UpdateClusterRequest request)

Updates the properties of a single cluster.

Parameter
Name Description
request UpdateClusterRequest
Returns
Type Description
Operation

updateConsumerGroup(UpdateConsumerGroupRequest request)

public ConsumerGroup updateConsumerGroup(UpdateConsumerGroupRequest request)

Updates the properties of a single consumer group.

Parameter
Name Description
request UpdateConsumerGroupRequest
Returns
Type Description
ConsumerGroup

updateTopic(UpdateTopicRequest request)

public Topic updateTopic(UpdateTopicRequest request)

Updates the properties of a single topic.

Parameter
Name Description
request UpdateTopicRequest
Returns
Type Description
Topic