Class ManagedKafkaGrpc.ManagedKafkaStub (0.20.0)

public static final class ManagedKafkaGrpc.ManagedKafkaStub extends AbstractAsyncStub<ManagedKafkaGrpc.ManagedKafkaStub>

A stub to allow clients to do asynchronous 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.AbstractAsyncStub > ManagedKafkaGrpc.ManagedKafkaStub

Inherited Members

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractAsyncStub.<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, StreamObserver<AddAclEntryResponse> responseObserver)

public void addAclEntry(AddAclEntryRequest request, StreamObserver<AddAclEntryResponse> responseObserver)

Incremental update: Adds an acl entry to an acl. Creates the acl if it does not exist yet.

Parameters
Name	Description
`request`	`AddAclEntryRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<AddAclEntryResponse>`

build(Channel channel, CallOptions callOptions)

protected ManagedKafkaGrpc.ManagedKafkaStub build(Channel channel, CallOptions callOptions)

Parameters
Name	Description
`channel`	`io.grpc.Channel`
`callOptions`	`io.grpc.CallOptions`

Returns
Type	Description
`ManagedKafkaGrpc.ManagedKafkaStub`

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

createAcl(CreateAclRequest request, StreamObserver<Acl> responseObserver)

public void createAcl(CreateAclRequest request, StreamObserver<Acl> responseObserver)

Creates a new acl in the given project, location, and cluster.

Parameters
Name	Description
`request`	`CreateAclRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Acl>`

createCluster(CreateClusterRequest request, StreamObserver<Operation> responseObserver)

public 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 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>`

deleteAcl(DeleteAclRequest request, StreamObserver<Empty> responseObserver)

public void deleteAcl(DeleteAclRequest request, StreamObserver<Empty> responseObserver)

Deletes an acl.

Parameters
Name	Description
`request`	`DeleteAclRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Empty>`

deleteCluster(DeleteClusterRequest request, StreamObserver<Operation> responseObserver)

public 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 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 void deleteTopic(DeleteTopicRequest request, StreamObserver<Empty> responseObserver)

Deletes a single topic.

Parameters
Name	Description
`request`	`DeleteTopicRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Empty>`

getAcl(GetAclRequest request, StreamObserver<Acl> responseObserver)

public void getAcl(GetAclRequest request, StreamObserver<Acl> responseObserver)

Returns the properties of a single acl.

Parameters
Name	Description
`request`	`GetAclRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Acl>`

getCluster(GetClusterRequest request, StreamObserver<Cluster> responseObserver)

public 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 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 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>`

listAcls(ListAclsRequest request, StreamObserver<ListAclsResponse> responseObserver)

public void listAcls(ListAclsRequest request, StreamObserver<ListAclsResponse> responseObserver)

Lists the acls in a given cluster.

Parameters
Name	Description
`request`	`ListAclsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListAclsResponse>`

listClusters(ListClustersRequest request, StreamObserver<ListClustersResponse> responseObserver)

public 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 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 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>`

removeAclEntry(RemoveAclEntryRequest request, StreamObserver<RemoveAclEntryResponse> responseObserver)

public void removeAclEntry(RemoveAclEntryRequest request, StreamObserver<RemoveAclEntryResponse> responseObserver)

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

Parameters
Name	Description
`request`	`RemoveAclEntryRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<RemoveAclEntryResponse>`

updateAcl(UpdateAclRequest request, StreamObserver<Acl> responseObserver)

public void updateAcl(UpdateAclRequest request, StreamObserver<Acl> responseObserver)

Updates the properties of a single acl.

Parameters
Name	Description
`request`	`UpdateAclRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Acl>`

updateCluster(UpdateClusterRequest request, StreamObserver<Operation> responseObserver)

public 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 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 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>`

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