Send feedback
Class ManagedKafkaGrpc.ManagedKafkaFutureStub (0.28.0)
Stay organized with collections
Save and categorize content based on your preferences.
Version latestkeyboard_arrow_down
public static final class ManagedKafkaGrpc . ManagedKafkaFutureStub extends AbstractFutureStub<ManagedKafkaGrpc . ManagedKafkaFutureStub >
A stub to allow clients to do ListenableFuture-style 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.AbstractFutureStub >
ManagedKafkaGrpc.ManagedKafkaFutureStub
Inherited Members
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractFutureStub.<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 ListenableFuture<AddAclEntryResponse> addAclEntry ( AddAclEntryRequest request )
Incremental update: Adds an acl entry to an acl. Creates the acl if it does
not exist yet.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <AddAclEntryResponse >
build(Channel channel, CallOptions callOptions)
protected ManagedKafkaGrpc . ManagedKafkaFutureStub build ( Channel channel , CallOptions callOptions )
Parameters
Name Description
channelio.grpc.Channel
callOptionsio.grpc.CallOptions
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
createAcl(CreateAclRequest request)
public ListenableFuture<Acl> createAcl ( CreateAclRequest request )
Creates a new acl in the given project, location, and cluster.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Acl >
createCluster(CreateClusterRequest request)
public ListenableFuture<Operation> createCluster ( CreateClusterRequest request )
Creates a new cluster in a given project and location.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
createTopic(CreateTopicRequest request)
public ListenableFuture<Topic> createTopic ( CreateTopicRequest request )
Creates a new topic in a given project and location.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Topic >
deleteAcl(DeleteAclRequest request)
public ListenableFuture<Empty> deleteAcl ( DeleteAclRequest request )
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Empty >
deleteCluster(DeleteClusterRequest request)
public ListenableFuture<Operation> deleteCluster ( DeleteClusterRequest request )
Deletes a single cluster.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
deleteConsumerGroup(DeleteConsumerGroupRequest request)
public ListenableFuture<Empty> deleteConsumerGroup ( DeleteConsumerGroupRequest request )
Deletes a single consumer group.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Empty >
deleteTopic(DeleteTopicRequest request)
public ListenableFuture<Empty> deleteTopic ( DeleteTopicRequest request )
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Empty >
getAcl(GetAclRequest request)
public ListenableFuture<Acl> getAcl ( GetAclRequest request )
Returns the properties of a single acl.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Acl >
getCluster(GetClusterRequest request)
public ListenableFuture<Cluster> getCluster ( GetClusterRequest request )
Returns the properties of a single cluster.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Cluster >
getConsumerGroup(GetConsumerGroupRequest request)
public ListenableFuture<ConsumerGroup> getConsumerGroup ( GetConsumerGroupRequest request )
Returns the properties of a single consumer group.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <ConsumerGroup >
getTopic(GetTopicRequest request)
public ListenableFuture<Topic> getTopic ( GetTopicRequest request )
Returns the properties of a single topic.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Topic >
listAcls(ListAclsRequest request)
public ListenableFuture<ListAclsResponse> listAcls ( ListAclsRequest request )
Lists the acls in a given cluster.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <ListAclsResponse >
listClusters(ListClustersRequest request)
public ListenableFuture<ListClustersResponse> listClusters ( ListClustersRequest request )
Lists the clusters in a given project and location.
listConsumerGroups(ListConsumerGroupsRequest request)
public ListenableFuture<ListConsumerGroupsResponse> listConsumerGroups ( ListConsumerGroupsRequest request )
Lists the consumer groups in a given cluster.
listTopics(ListTopicsRequest request)
public ListenableFuture<ListTopicsResponse> listTopics ( ListTopicsRequest request )
Lists the topics in a given cluster.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <ListTopicsResponse >
removeAclEntry(RemoveAclEntryRequest request)
public ListenableFuture<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 ListenableFuture<Acl> updateAcl ( UpdateAclRequest request )
Updates the properties of a single acl.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Acl >
updateCluster(UpdateClusterRequest request)
public ListenableFuture<Operation> updateCluster ( UpdateClusterRequest request )
Updates the properties of a single cluster.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
updateConsumerGroup(UpdateConsumerGroupRequest request)
public ListenableFuture<ConsumerGroup> updateConsumerGroup ( UpdateConsumerGroupRequest request )
Updates the properties of a single consumer group.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <ConsumerGroup >
updateTopic(UpdateTopicRequest request)
public ListenableFuture<Topic> updateTopic ( UpdateTopicRequest request )
Updates the properties of a single topic.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Topic >
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-08-18 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-18 UTC."],[],[],null,[]]
