public static interface ManagedKafkaGrpc.AsyncServiceThe service that a client application uses to manage Apache Kafka clusters, topics and consumer groups.
Methods
createCluster(CreateClusterRequest request, StreamObserver<Operation> responseObserver)
public default void createCluster(CreateClusterRequest request, StreamObserver<Operation> responseObserver)Creates a new cluster in a given project and location.
| Parameters | |
|---|---|
| Name | Description |
request |
CreateClusterRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
createTopic(CreateTopicRequest request, StreamObserver<Topic> responseObserver)
public default void createTopic(CreateTopicRequest request, StreamObserver<Topic> responseObserver)Creates a new topic in a given project and location.
| Parameters | |
|---|---|
| Name | Description |
request |
CreateTopicRequest |
responseObserver |
io.grpc.stub.StreamObserver<Topic> |
deleteCluster(DeleteClusterRequest request, StreamObserver<Operation> responseObserver)
public default void deleteCluster(DeleteClusterRequest request, StreamObserver<Operation> responseObserver)Deletes a single cluster.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteClusterRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
deleteConsumerGroup(DeleteConsumerGroupRequest request, StreamObserver<Empty> responseObserver)
public default void deleteConsumerGroup(DeleteConsumerGroupRequest request, StreamObserver<Empty> responseObserver)Deletes a single consumer group.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteConsumerGroupRequest |
responseObserver |
io.grpc.stub.StreamObserver<Empty> |
deleteTopic(DeleteTopicRequest request, StreamObserver<Empty> responseObserver)
public default void deleteTopic(DeleteTopicRequest request, StreamObserver<Empty> responseObserver)Deletes a single topic.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteTopicRequest |
responseObserver |
io.grpc.stub.StreamObserver<Empty> |
getCluster(GetClusterRequest request, StreamObserver<Cluster> responseObserver)
public default void getCluster(GetClusterRequest request, StreamObserver<Cluster> responseObserver)Returns the properties of a single cluster.
| Parameters | |
|---|---|
| Name | Description |
request |
GetClusterRequest |
responseObserver |
io.grpc.stub.StreamObserver<Cluster> |
getConsumerGroup(GetConsumerGroupRequest request, StreamObserver<ConsumerGroup> responseObserver)
public default void getConsumerGroup(GetConsumerGroupRequest request, StreamObserver<ConsumerGroup> responseObserver)Returns the properties of a single consumer group.
| Parameters | |
|---|---|
| Name | Description |
request |
GetConsumerGroupRequest |
responseObserver |
io.grpc.stub.StreamObserver<ConsumerGroup> |
getTopic(GetTopicRequest request, StreamObserver<Topic> responseObserver)
public default void getTopic(GetTopicRequest request, StreamObserver<Topic> responseObserver)Returns the properties of a single topic.
| Parameters | |
|---|---|
| Name | Description |
request |
GetTopicRequest |
responseObserver |
io.grpc.stub.StreamObserver<Topic> |
listClusters(ListClustersRequest request, StreamObserver<ListClustersResponse> responseObserver)
public default void listClusters(ListClustersRequest request, StreamObserver<ListClustersResponse> responseObserver)Lists the clusters in a given project and location.
| Parameters | |
|---|---|
| Name | Description |
request |
ListClustersRequest |
responseObserver |
io.grpc.stub.StreamObserver<ListClustersResponse> |
listConsumerGroups(ListConsumerGroupsRequest request, StreamObserver<ListConsumerGroupsResponse> responseObserver)
public default void listConsumerGroups(ListConsumerGroupsRequest request, StreamObserver<ListConsumerGroupsResponse> responseObserver)Lists the consumer groups in a given cluster.
| Parameters | |
|---|---|
| Name | Description |
request |
ListConsumerGroupsRequest |
responseObserver |
io.grpc.stub.StreamObserver<ListConsumerGroupsResponse> |
listTopics(ListTopicsRequest request, StreamObserver<ListTopicsResponse> responseObserver)
public default void listTopics(ListTopicsRequest request, StreamObserver<ListTopicsResponse> responseObserver)Lists the topics in a given cluster.
| Parameters | |
|---|---|
| Name | Description |
request |
ListTopicsRequest |
responseObserver |
io.grpc.stub.StreamObserver<ListTopicsResponse> |
updateCluster(UpdateClusterRequest request, StreamObserver<Operation> responseObserver)
public default void updateCluster(UpdateClusterRequest request, StreamObserver<Operation> responseObserver)Updates the properties of a single cluster.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateClusterRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
updateConsumerGroup(UpdateConsumerGroupRequest request, StreamObserver<ConsumerGroup> responseObserver)
public default void updateConsumerGroup(UpdateConsumerGroupRequest request, StreamObserver<ConsumerGroup> responseObserver)Updates the properties of a single consumer group.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateConsumerGroupRequest |
responseObserver |
io.grpc.stub.StreamObserver<ConsumerGroup> |
updateTopic(UpdateTopicRequest request, StreamObserver<Topic> responseObserver)
public default void updateTopic(UpdateTopicRequest request, StreamObserver<Topic> responseObserver)Updates the properties of a single topic.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateTopicRequest |
responseObserver |
io.grpc.stub.StreamObserver<Topic> |