public static final class ManagedKafkaGrpc.ManagedKafkaBlockingStub extends AbstractBlockingStub<ManagedKafkaGrpc.ManagedKafkaBlockingStub>
A stub to allow clients to do limited 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
Inherited Members
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.getCallOptions()
io.grpc.stub.AbstractStub.getChannel()
io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)
io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)
io.grpc.stub.AbstractStub.withCompression(java.lang.String)
io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)
io.grpc.stub.AbstractStub.withDeadlineAfter(java.time.Duration)
io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)
io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)
io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)
io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)
io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)
io.grpc.stub.AbstractStub.withOnReadyThreshold(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
addAclEntry(AddAclEntryRequest request)
public AddAclEntryResponse addAclEntry(AddAclEntryRequest request)
Incremental update: Adds an acl entry to an acl. Creates the acl if it does
not exist yet.
build(Channel channel, CallOptions callOptions)
protected ManagedKafkaGrpc.ManagedKafkaBlockingStub build(Channel channel, CallOptions callOptions)
| Parameters |
| Name |
Description |
channel |
io.grpc.Channel
|
callOptions |
io.grpc.CallOptions
|
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
createAcl(CreateAclRequest request)
public Acl createAcl(CreateAclRequest request)
Creates a new acl in the given project, location, and cluster.
| Returns |
| Type |
Description |
Acl |
|
createCluster(CreateClusterRequest request)
public Operation createCluster(CreateClusterRequest request)
Creates a new cluster in a given project and location.
createTopic(CreateTopicRequest request)
public Topic createTopic(CreateTopicRequest request)
Creates a new topic in a given project and location.
| Returns |
| Type |
Description |
Topic |
|
deleteAcl(DeleteAclRequest request)
public Empty deleteAcl(DeleteAclRequest request)
| Returns |
| Type |
Description |
Empty |
|
deleteCluster(DeleteClusterRequest request)
public Operation deleteCluster(DeleteClusterRequest request)
Deletes a single cluster.
deleteConsumerGroup(DeleteConsumerGroupRequest request)
public Empty deleteConsumerGroup(DeleteConsumerGroupRequest request)
Deletes a single consumer group.
| Returns |
| Type |
Description |
Empty |
|
deleteTopic(DeleteTopicRequest request)
public Empty deleteTopic(DeleteTopicRequest request)
| Returns |
| Type |
Description |
Empty |
|
getAcl(GetAclRequest request)
public Acl getAcl(GetAclRequest request)
Returns the properties of a single acl.
| Returns |
| Type |
Description |
Acl |
|
getCluster(GetClusterRequest request)
public Cluster getCluster(GetClusterRequest request)
Returns the properties of a single cluster.
getConsumerGroup(GetConsumerGroupRequest request)
public ConsumerGroup getConsumerGroup(GetConsumerGroupRequest request)
Returns the properties of a single consumer group.
getTopic(GetTopicRequest request)
public Topic getTopic(GetTopicRequest request)
Returns the properties of a single topic.
| Returns |
| Type |
Description |
Topic |
|
listAcls(ListAclsRequest request)
public ListAclsResponse listAcls(ListAclsRequest request)
Lists the acls in a given cluster.
listClusters(ListClustersRequest request)
public ListClustersResponse listClusters(ListClustersRequest request)
Lists the clusters in a given project and location.
listConsumerGroups(ListConsumerGroupsRequest request)
public ListConsumerGroupsResponse listConsumerGroups(ListConsumerGroupsRequest request)
Lists the consumer groups in a given cluster.
listTopics(ListTopicsRequest request)
public ListTopicsResponse listTopics(ListTopicsRequest request)
Lists the topics in a given cluster.
removeAclEntry(RemoveAclEntryRequest request)
public RemoveAclEntryResponse removeAclEntry(RemoveAclEntryRequest request)
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).
updateAcl(UpdateAclRequest request)
public Acl updateAcl(UpdateAclRequest request)
Updates the properties of a single acl.
| Returns |
| Type |
Description |
Acl |
|
updateCluster(UpdateClusterRequest request)
public Operation updateCluster(UpdateClusterRequest request)
Updates the properties of a single cluster.
updateConsumerGroup(UpdateConsumerGroupRequest request)
public ConsumerGroup updateConsumerGroup(UpdateConsumerGroupRequest request)
Updates the properties of a single consumer group.
updateTopic(UpdateTopicRequest request)
public Topic updateTopic(UpdateTopicRequest request)
Updates the properties of a single topic.
| Returns |
| Type |
Description |
Topic |
|
