Class ManagedKafkaConnectGrpc.ManagedKafkaConnectFutureStub (0.43.0)

0.43.0 (latest) 0.41.0 0.39.0 0.38.0 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 ManagedKafkaConnectGrpc.ManagedKafkaConnectFutureStub extends AbstractFutureStub<ManagedKafkaConnectGrpc.ManagedKafkaConnectFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service ManagedKafkaConnect.

The service that a client application uses to manage Apache Kafka Connect clusters and connectors.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractFutureStub > ManagedKafkaConnectGrpc.ManagedKafkaConnectFutureStub

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

build(Channel channel, CallOptions callOptions)

protected ManagedKafkaConnectGrpc.ManagedKafkaConnectFutureStub build(Channel channel, CallOptions callOptions)

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

Returns
Type	Description
ManagedKafkaConnectGrpc.ManagedKafkaConnectFutureStub

Overrides

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

createConnectCluster(CreateConnectClusterRequest request)

public ListenableFuture<Operation> createConnectCluster(CreateConnectClusterRequest request)

Creates a new Kafka Connect cluster in a given project and location.

Parameter
Name	Description
request	CreateConnectClusterRequest

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

createConnector(CreateConnectorRequest request)

public ListenableFuture<Connector> createConnector(CreateConnectorRequest request)

Creates a new connector in a given Connect cluster.

Parameter
Name	Description
request	CreateConnectorRequest

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

deleteConnectCluster(DeleteConnectClusterRequest request)

public ListenableFuture<Operation> deleteConnectCluster(DeleteConnectClusterRequest request)

Deletes a single Connect cluster.

Parameter
Name	Description
request	DeleteConnectClusterRequest

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

deleteConnector(DeleteConnectorRequest request)

public ListenableFuture<Empty> deleteConnector(DeleteConnectorRequest request)

Deletes a connector.

Parameter
Name	Description
request	DeleteConnectorRequest

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

getConnectCluster(GetConnectClusterRequest request)

public ListenableFuture<ConnectCluster> getConnectCluster(GetConnectClusterRequest request)

Returns the properties of a single Kafka Connect cluster.

Parameter
Name	Description
request	GetConnectClusterRequest

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

getConnector(GetConnectorRequest request)

public ListenableFuture<Connector> getConnector(GetConnectorRequest request)

Returns the properties of a single connector.

Parameter
Name	Description
request	GetConnectorRequest

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

listConnectClusters(ListConnectClustersRequest request)

public ListenableFuture<ListConnectClustersResponse> listConnectClusters(ListConnectClustersRequest request)

Lists the Kafka Connect clusters in a given project and location.

Parameter
Name	Description
request	ListConnectClustersRequest

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

listConnectors(ListConnectorsRequest request)

public ListenableFuture<ListConnectorsResponse> listConnectors(ListConnectorsRequest request)

Lists the connectors in a given Connect cluster.

Parameter
Name	Description
request	ListConnectorsRequest

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

pauseConnector(PauseConnectorRequest request)

public ListenableFuture<PauseConnectorResponse> pauseConnector(PauseConnectorRequest request)

Pauses the connector and its tasks.

Parameter
Name	Description
request	PauseConnectorRequest

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

restartConnector(RestartConnectorRequest request)

public ListenableFuture<RestartConnectorResponse> restartConnector(RestartConnectorRequest request)

Restarts the connector.

Parameter
Name	Description
request	RestartConnectorRequest

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

resumeConnector(ResumeConnectorRequest request)

public ListenableFuture<ResumeConnectorResponse> resumeConnector(ResumeConnectorRequest request)

Resumes the connector and its tasks.

Parameter
Name	Description
request	ResumeConnectorRequest

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

stopConnector(StopConnectorRequest request)

public ListenableFuture<StopConnectorResponse> stopConnector(StopConnectorRequest request)

Stops the connector.

Parameter
Name	Description
request	StopConnectorRequest

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

updateConnectCluster(UpdateConnectClusterRequest request)

public ListenableFuture<Operation> updateConnectCluster(UpdateConnectClusterRequest request)

Updates the properties of a single Kafka Connect cluster.

Parameter
Name	Description
request	UpdateConnectClusterRequest

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

updateConnector(UpdateConnectorRequest request)

public ListenableFuture<Connector> updateConnector(UpdateConnectorRequest request)

Updates the properties of a connector.

Parameter
Name	Description
request	UpdateConnectorRequest

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