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

Class ManagedKafkaConnectGrpc.ManagedKafkaConnectFutureStub (0.28.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>`