Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

Class ManagedKafkaGrpc.ManagedKafkaBlockingStub (0.2.0)

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

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

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)

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`

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`

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`

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`

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`