Class ManagedKafkaConnectGrpc.ManagedKafkaConnectBlockingStub (0.16.1)

public static final class ManagedKafkaConnectGrpc.ManagedKafkaConnectBlockingStub extends AbstractBlockingStub<ManagedKafkaConnectGrpc.ManagedKafkaConnectBlockingStub>

A stub to allow clients to do synchronous 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.AbstractBlockingStub > ManagedKafkaConnectGrpc.ManagedKafkaConnectBlockingStub

Methods

build(Channel channel, CallOptions callOptions)

protected ManagedKafkaConnectGrpc.ManagedKafkaConnectBlockingStub build(Channel channel, CallOptions callOptions)
Parameters
Name Description
channel io.grpc.Channel
callOptions io.grpc.CallOptions
Returns
Type Description
ManagedKafkaConnectGrpc.ManagedKafkaConnectBlockingStub
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

createConnectCluster(CreateConnectClusterRequest request)

public Operation createConnectCluster(CreateConnectClusterRequest request)

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

Parameter
Name Description
request CreateConnectClusterRequest
Returns
Type Description
Operation

createConnector(CreateConnectorRequest request)

public Connector createConnector(CreateConnectorRequest request)

Creates a new connector in a given Connect cluster.

Parameter
Name Description
request CreateConnectorRequest
Returns
Type Description
Connector

deleteConnectCluster(DeleteConnectClusterRequest request)

public Operation deleteConnectCluster(DeleteConnectClusterRequest request)

Deletes a single Connect cluster.

Parameter
Name Description
request DeleteConnectClusterRequest
Returns
Type Description
Operation

deleteConnector(DeleteConnectorRequest request)

public Empty deleteConnector(DeleteConnectorRequest request)

Deletes a connector.

Parameter
Name Description
request DeleteConnectorRequest
Returns
Type Description
Empty

getConnectCluster(GetConnectClusterRequest request)

public ConnectCluster getConnectCluster(GetConnectClusterRequest request)

Returns the properties of a single Kafka Connect cluster.

Parameter
Name Description
request GetConnectClusterRequest
Returns
Type Description
ConnectCluster

getConnector(GetConnectorRequest request)

public Connector getConnector(GetConnectorRequest request)

Returns the properties of a single connector.

Parameter
Name Description
request GetConnectorRequest
Returns
Type Description
Connector

listConnectClusters(ListConnectClustersRequest request)

public ListConnectClustersResponse listConnectClusters(ListConnectClustersRequest request)

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

Parameter
Name Description
request ListConnectClustersRequest
Returns
Type Description
ListConnectClustersResponse

listConnectors(ListConnectorsRequest request)

public ListConnectorsResponse listConnectors(ListConnectorsRequest request)

Lists the connectors in a given Connect cluster.

Parameter
Name Description
request ListConnectorsRequest
Returns
Type Description
ListConnectorsResponse

pauseConnector(PauseConnectorRequest request)

public PauseConnectorResponse pauseConnector(PauseConnectorRequest request)

Pauses the connector and its tasks.

Parameter
Name Description
request PauseConnectorRequest
Returns
Type Description
PauseConnectorResponse

restartConnector(RestartConnectorRequest request)

public RestartConnectorResponse restartConnector(RestartConnectorRequest request)

Restarts the connector.

Parameter
Name Description
request RestartConnectorRequest
Returns
Type Description
RestartConnectorResponse

resumeConnector(ResumeConnectorRequest request)

public ResumeConnectorResponse resumeConnector(ResumeConnectorRequest request)

Resumes the connector and its tasks.

Parameter
Name Description
request ResumeConnectorRequest
Returns
Type Description
ResumeConnectorResponse

stopConnector(StopConnectorRequest request)

public StopConnectorResponse stopConnector(StopConnectorRequest request)

Stops the connector.

Parameter
Name Description
request StopConnectorRequest
Returns
Type Description
StopConnectorResponse

updateConnectCluster(UpdateConnectClusterRequest request)

public Operation updateConnectCluster(UpdateConnectClusterRequest request)

Updates the properties of a single Kafka Connect cluster.

Parameter
Name Description
request UpdateConnectClusterRequest
Returns
Type Description
Operation

updateConnector(UpdateConnectorRequest request)

public Connector updateConnector(UpdateConnectorRequest request)

Updates the properties of a connector.

Parameter
Name Description
request UpdateConnectorRequest
Returns
Type Description
Connector