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.ManagedKafkaBlockingStubMethods
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 |
|
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 |
|