Class ManagedKafkaGrpc.ManagedKafkaBlockingV2Stub (0.38.0)

Version latest

• 0.38.0 (latest)
• 0.37.0
• 0.36.0
• 0.34.0
• 0.32.0
• 0.31.0
• 0.30.0
• 0.29.0
• 0.28.0
• 0.26.0
• 0.24.0
• 0.23.0
• 0.20.0
• 0.19.0
• 0.18.0
• 0.16.1
• 0.15.0
• 0.14.0
• 0.13.0
• 0.12.0
• 0.11.0
• 0.10.0
• 0.9.0
• 0.8.0
• 0.7.0
• 0.5.0
• 0.4.0
• 0.3.0
• 0.2.0
• 0.1.0

public static final class ManagedKafkaGrpc.ManagedKafkaBlockingV2Stub extends AbstractBlockingStub<ManagedKafkaGrpc.ManagedKafkaBlockingV2Stub>

A stub to allow clients to do 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.ManagedKafkaBlockingV2Stub

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

Exceptions
Type	Description
io.grpc.StatusException

build(Channel channel, CallOptions callOptions)

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

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

Returns
Type	Description
ManagedKafkaGrpc.ManagedKafkaBlockingV2Stub

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

Exceptions
Type	Description
io.grpc.StatusException

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

Exceptions
Type	Description
io.grpc.StatusException

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

Exceptions
Type	Description
io.grpc.StatusException

deleteAcl(DeleteAclRequest request)

public Empty deleteAcl(DeleteAclRequest request)

Deletes an acl.

Parameter
Name	Description
request	DeleteAclRequest

Returns
Type	Description
Empty

Exceptions
Type	Description
io.grpc.StatusException

deleteCluster(DeleteClusterRequest request)

public Operation deleteCluster(DeleteClusterRequest request)

Deletes a single cluster.

Parameter
Name	Description
request	DeleteClusterRequest

Returns
Type	Description
Operation

Exceptions
Type	Description
io.grpc.StatusException

deleteConsumerGroup(DeleteConsumerGroupRequest request)

public Empty deleteConsumerGroup(DeleteConsumerGroupRequest request)

Deletes a single consumer group.

Parameter
Name	Description
request	DeleteConsumerGroupRequest

Returns
Type	Description
Empty

Exceptions
Type	Description
io.grpc.StatusException

deleteTopic(DeleteTopicRequest request)

public Empty deleteTopic(DeleteTopicRequest request)

Deletes a single topic.

Parameter
Name	Description
request	DeleteTopicRequest

Returns
Type	Description
Empty

Exceptions
Type	Description
io.grpc.StatusException

getAcl(GetAclRequest request)

public Acl getAcl(GetAclRequest request)

Returns the properties of a single acl.

Parameter
Name	Description
request	GetAclRequest

Returns
Type	Description
Acl

Exceptions
Type	Description
io.grpc.StatusException

getCluster(GetClusterRequest request)

public Cluster getCluster(GetClusterRequest request)

Returns the properties of a single cluster.

Parameter
Name	Description
request	GetClusterRequest

Returns
Type	Description
Cluster

Exceptions
Type	Description
io.grpc.StatusException

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

Exceptions
Type	Description
io.grpc.StatusException

getTopic(GetTopicRequest request)

public Topic getTopic(GetTopicRequest request)

Returns the properties of a single topic.

Parameter
Name	Description
request	GetTopicRequest

Returns
Type	Description
Topic

Exceptions
Type	Description
io.grpc.StatusException

listAcls(ListAclsRequest request)

public ListAclsResponse listAcls(ListAclsRequest request)

Lists the acls in a given cluster.

Parameter
Name	Description
request	ListAclsRequest

Returns
Type	Description
ListAclsResponse

Exceptions
Type	Description
io.grpc.StatusException

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

Exceptions
Type	Description
io.grpc.StatusException

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

Exceptions
Type	Description
io.grpc.StatusException

listTopics(ListTopicsRequest request)

public ListTopicsResponse listTopics(ListTopicsRequest request)

Lists the topics in a given cluster.

Parameter
Name	Description
request	ListTopicsRequest

Returns
Type	Description
ListTopicsResponse

Exceptions
Type	Description
io.grpc.StatusException

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

Exceptions
Type	Description
io.grpc.StatusException

updateAcl(UpdateAclRequest request)

public Acl updateAcl(UpdateAclRequest request)

Updates the properties of a single acl.

Parameter
Name	Description
request	UpdateAclRequest

Returns
Type	Description
Acl

Exceptions
Type	Description
io.grpc.StatusException

updateCluster(UpdateClusterRequest request)

public Operation updateCluster(UpdateClusterRequest request)

Updates the properties of a single cluster.

Parameter
Name	Description
request	UpdateClusterRequest

Returns
Type	Description
Operation

Exceptions
Type	Description
io.grpc.StatusException

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

Exceptions
Type	Description
io.grpc.StatusException

updateTopic(UpdateTopicRequest request)

public Topic updateTopic(UpdateTopicRequest request)

Updates the properties of a single topic.

Parameter
Name	Description
request	UpdateTopicRequest

Returns
Type	Description
Topic

Exceptions
Type	Description
io.grpc.StatusException