Class ManagedKafkaGrpc.ManagedKafkaFutureStub (0.20.0)

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()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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.

Parameter
Name	Description
`request`	`AddAclEntryRequest`

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
`channel`	`io.grpc.Channel`
`callOptions`	`io.grpc.CallOptions`

Returns
Type	Description
`ManagedKafkaGrpc.ManagedKafkaFutureStub`

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.

Parameter
Name	Description
`request`	`CreateAclRequest`

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.

Parameter
Name	Description
`request`	`CreateClusterRequest`

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.

Parameter
Name	Description
`request`	`CreateTopicRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Topic>`

deleteAcl(DeleteAclRequest request)

public ListenableFuture<Empty> deleteAcl(DeleteAclRequest request)

Deletes an acl.

Parameter
Name	Description
`request`	`DeleteAclRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Empty>`

deleteCluster(DeleteClusterRequest request)

public ListenableFuture<Operation> deleteCluster(DeleteClusterRequest request)

Deletes a single cluster.

Parameter
Name	Description
`request`	`DeleteClusterRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Operation>`

deleteConsumerGroup(DeleteConsumerGroupRequest request)

public ListenableFuture<Empty> deleteConsumerGroup(DeleteConsumerGroupRequest request)

Deletes a single consumer group.

Parameter
Name	Description
`request`	`DeleteConsumerGroupRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Empty>`

deleteTopic(DeleteTopicRequest request)

public ListenableFuture<Empty> deleteTopic(DeleteTopicRequest request)

Deletes a single topic.

Parameter
Name	Description
`request`	`DeleteTopicRequest`

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.

Parameter
Name	Description
`request`	`GetAclRequest`

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.

Parameter
Name	Description
`request`	`GetClusterRequest`

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.

Parameter
Name	Description
`request`	`GetConsumerGroupRequest`

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.

Parameter
Name	Description
`request`	`GetTopicRequest`

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.

Parameter
Name	Description
`request`	`ListAclsRequest`

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.

Parameter
Name	Description
`request`	`ListClustersRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<ListClustersResponse>`

listConsumerGroups(ListConsumerGroupsRequest request)

public ListenableFuture<ListConsumerGroupsResponse> listConsumerGroups(ListConsumerGroupsRequest request)

Lists the consumer groups in a given cluster.

Parameter
Name	Description
`request`	`ListConsumerGroupsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<ListConsumerGroupsResponse>`

listTopics(ListTopicsRequest request)

public ListenableFuture<ListTopicsResponse> listTopics(ListTopicsRequest request)

Lists the topics in a given cluster.

Parameter
Name	Description
`request`	`ListTopicsRequest`

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

Parameter
Name	Description
`request`	`RemoveAclEntryRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<RemoveAclEntryResponse>`

updateAcl(UpdateAclRequest request)

public ListenableFuture<Acl> updateAcl(UpdateAclRequest request)

Updates the properties of a single acl.

Parameter
Name	Description
`request`	`UpdateAclRequest`

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.

Parameter
Name	Description
`request`	`UpdateClusterRequest`

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.

Parameter
Name	Description
`request`	`UpdateConsumerGroupRequest`

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.

Parameter
Name	Description
`request`	`UpdateTopicRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Topic>`

Class ManagedKafkaGrpc.ManagedKafkaFutureStub (0.20.0) Stay organized with collections Save and categorize content based on your preferences.