Class ManagedKafkaConnectGrpc.ManagedKafkaConnectFutureStub (0.16.1)

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

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>