Class ManagedKafkaGrpc.ManagedKafkaBlockingStub (0.28.0)

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

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

build(Channel channel, CallOptions callOptions)

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

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

Returns
Type	Description
`ManagedKafkaGrpc.ManagedKafkaBlockingStub`

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.

Parameter
Name	Description
`request`	`CreateAclRequest`

Returns
Type	Description
`Acl`

createCluster(CreateClusterRequest request)

public Operation createCluster(CreateClusterRequest request)

Creates a new cluster in a given project and location.

Parameter
Name	Description
`request`	`CreateClusterRequest`

Returns
Type	Description
`Operation`

createTopic(CreateTopicRequest request)

public Topic createTopic(CreateTopicRequest request)

Creates a new topic in a given project and location.

Parameter
Name	Description
`request`	`CreateTopicRequest`

Returns
Type	Description
`Topic`

deleteAcl(DeleteAclRequest request)

public Empty deleteAcl(DeleteAclRequest request)

Deletes an acl.

Parameter
Name	Description
`request`	`DeleteAclRequest`

Returns
Type	Description
`Empty`

deleteCluster(DeleteClusterRequest request)

public Operation deleteCluster(DeleteClusterRequest request)

Deletes a single cluster.

Parameter
Name	Description
`request`	`DeleteClusterRequest`

Returns
Type	Description
`Operation`

deleteConsumerGroup(DeleteConsumerGroupRequest request)

public Empty deleteConsumerGroup(DeleteConsumerGroupRequest request)

Deletes a single consumer group.

Parameter
Name	Description
`request`	`DeleteConsumerGroupRequest`

Returns
Type	Description
`Empty`

deleteTopic(DeleteTopicRequest request)

public Empty deleteTopic(DeleteTopicRequest request)

Deletes a single topic.

Parameter
Name	Description
`request`	`DeleteTopicRequest`

Returns
Type	Description
`Empty`

getAcl(GetAclRequest request)

public Acl getAcl(GetAclRequest request)

Returns the properties of a single acl.

Parameter
Name	Description
`request`	`GetAclRequest`

Returns
Type	Description
`Acl`

getCluster(GetClusterRequest request)

public Cluster getCluster(GetClusterRequest request)

Returns the properties of a single cluster.

Parameter
Name	Description
`request`	`GetClusterRequest`

Returns
Type	Description
`Cluster`

getConsumerGroup(GetConsumerGroupRequest request)

public ConsumerGroup getConsumerGroup(GetConsumerGroupRequest request)

Returns the properties of a single consumer group.

Parameter
Name	Description
`request`	`GetConsumerGroupRequest`

Returns
Type	Description
`ConsumerGroup`

getTopic(GetTopicRequest request)

public Topic getTopic(GetTopicRequest request)

Returns the properties of a single topic.

Parameter
Name	Description
`request`	`GetTopicRequest`

Returns
Type	Description
`Topic`

listAcls(ListAclsRequest request)

public ListAclsResponse listAcls(ListAclsRequest request)

Lists the acls in a given cluster.

Parameter
Name	Description
`request`	`ListAclsRequest`

Returns
Type	Description
`ListAclsResponse`

listClusters(ListClustersRequest request)

public ListClustersResponse listClusters(ListClustersRequest request)

Lists the clusters in a given project and location.

Parameter
Name	Description
`request`	`ListClustersRequest`

Returns
Type	Description
`ListClustersResponse`

listConsumerGroups(ListConsumerGroupsRequest request)

public ListConsumerGroupsResponse listConsumerGroups(ListConsumerGroupsRequest request)

Lists the consumer groups in a given cluster.

Parameter
Name	Description
`request`	`ListConsumerGroupsRequest`

Returns
Type	Description
`ListConsumerGroupsResponse`

listTopics(ListTopicsRequest request)

public ListTopicsResponse listTopics(ListTopicsRequest request)

Lists the topics in a given cluster.

Parameter
Name	Description
`request`	`ListTopicsRequest`

Returns
Type	Description
`ListTopicsResponse`

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

Parameter
Name	Description
`request`	`RemoveAclEntryRequest`

Returns
Type	Description
`RemoveAclEntryResponse`

updateAcl(UpdateAclRequest request)

public Acl updateAcl(UpdateAclRequest request)

Updates the properties of a single acl.

Parameter
Name	Description
`request`	`UpdateAclRequest`

Returns
Type	Description
`Acl`

updateCluster(UpdateClusterRequest request)

public Operation updateCluster(UpdateClusterRequest request)

Updates the properties of a single cluster.

Parameter
Name	Description
`request`	`UpdateClusterRequest`

Returns
Type	Description
`Operation`

updateConsumerGroup(UpdateConsumerGroupRequest request)

public ConsumerGroup updateConsumerGroup(UpdateConsumerGroupRequest request)

Updates the properties of a single consumer group.

Parameter
Name	Description
`request`	`UpdateConsumerGroupRequest`

Returns
Type	Description
`ConsumerGroup`

updateTopic(UpdateTopicRequest request)

public Topic updateTopic(UpdateTopicRequest request)

Updates the properties of a single topic.

Parameter
Name	Description
`request`	`UpdateTopicRequest`

Returns
Type	Description
`Topic`

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