Managed Service for Apache Kafka API v1 API - Class ManagedKafkaConnect.ManagedKafkaConnectClient (1.0.0-beta05)
Stay organized with collections Save and categorize content based on your preferences.

public class ManagedKafkaConnect.ManagedKafkaConnectClient : ClientBase<ManagedKafkaConnect.ManagedKafkaConnectClient>

Reference documentation and code samples for the Managed Service for Apache Kafka API v1 API class ManagedKafkaConnect.ManagedKafkaConnectClient.

Client for ManagedKafkaConnect

Inheritance

object > ClientBase > ClientBase ManagedKafkaConnect ManagedKafkaConnectClient > ManagedKafkaConnect.ManagedKafkaConnectClient

Inherited Members

ClientBase<ManagedKafkaConnect.ManagedKafkaConnectClient>.WithHost(string)

ClientBase.CallInvoker

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ToString()

Namespace

Google.Cloud.ManagedKafka.V1

Assembly

Google.Cloud.ManagedKafka.V1.dll

Constructors

ManagedKafkaConnectClient()

protected ManagedKafkaConnectClient()

Protected parameterless constructor to allow creation of test doubles.

ManagedKafkaConnectClient(CallInvoker)

public ManagedKafkaConnectClient(CallInvoker callInvoker)

Creates a new client for ManagedKafkaConnect that uses a custom CallInvoker.

Parameter
Name	Description
`callInvoker`	`CallInvoker` The callInvoker to use to make remote calls.

ManagedKafkaConnectClient(ChannelBase)

public ManagedKafkaConnectClient(ChannelBase channel)

Creates a new client for ManagedKafkaConnect

Parameter
Name	Description
`channel`	`ChannelBase` The channel to use to make remote calls.

ManagedKafkaConnectClient(ClientBaseConfiguration)

protected ManagedKafkaConnectClient(ClientBase.ClientBaseConfiguration configuration)

Protected constructor to allow creation of configured clients.

Parameter
Name	Description
`configuration`	`ClientBaseClientBaseConfiguration` The client configuration.

Methods

CreateConnectCluster(CreateConnectClusterRequest, CallOptions)

public virtual Operation CreateConnectCluster(CreateConnectClusterRequest request, CallOptions options)

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

Parameters
Name	Description
`request`	`CreateConnectClusterRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`Operation`	The response received from the server.

CreateConnectCluster(CreateConnectClusterRequest, Metadata, DateTime?, CancellationToken)

public virtual Operation CreateConnectCluster(CreateConnectClusterRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

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

Parameters
Name	Description
`request`	`CreateConnectClusterRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`Operation`	The response received from the server.

CreateConnectClusterAsync(CreateConnectClusterRequest, CallOptions)

public virtual AsyncUnaryCall<Operation> CreateConnectClusterAsync(CreateConnectClusterRequest request, CallOptions options)

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

Parameters
Name	Description
`request`	`CreateConnectClusterRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallOperation`	The call object.

CreateConnectClusterAsync(CreateConnectClusterRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<Operation> CreateConnectClusterAsync(CreateConnectClusterRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

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

Parameters
Name	Description
`request`	`CreateConnectClusterRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallOperation`	The call object.

CreateConnector(CreateConnectorRequest, CallOptions)

public virtual Connector CreateConnector(CreateConnectorRequest request, CallOptions options)

Creates a new connector in a given Connect cluster.

Parameters
Name	Description
`request`	`CreateConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`Connector`	The response received from the server.

CreateConnector(CreateConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual Connector CreateConnector(CreateConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Creates a new connector in a given Connect cluster.

Parameters
Name	Description
`request`	`CreateConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`Connector`	The response received from the server.

CreateConnectorAsync(CreateConnectorRequest, CallOptions)

public virtual AsyncUnaryCall<Connector> CreateConnectorAsync(CreateConnectorRequest request, CallOptions options)

Creates a new connector in a given Connect cluster.

Parameters
Name	Description
`request`	`CreateConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallConnector`	The call object.

CreateConnectorAsync(CreateConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<Connector> CreateConnectorAsync(CreateConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Creates a new connector in a given Connect cluster.

Parameters
Name	Description
`request`	`CreateConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallConnector`	The call object.

CreateLocationsClient()

public virtual Locations.LocationsClient CreateLocationsClient()

Creates a new instance of Locations.LocationsClient using the same call invoker as this client.

Returns
Type	Description
`LocationsLocationsClient`	A new Locations.LocationsClient for the same target as this client.

CreateOperationsClient()

public virtual Operations.OperationsClient CreateOperationsClient()

Creates a new instance of Operations.OperationsClient using the same call invoker as this client.

Returns
Type	Description
`OperationsOperationsClient`	A new Operations client for the same target as this client.

DeleteConnectCluster(DeleteConnectClusterRequest, CallOptions)

public virtual Operation DeleteConnectCluster(DeleteConnectClusterRequest request, CallOptions options)

Deletes a single Connect cluster.

Parameters
Name	Description
`request`	`DeleteConnectClusterRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`Operation`	The response received from the server.

DeleteConnectCluster(DeleteConnectClusterRequest, Metadata, DateTime?, CancellationToken)

public virtual Operation DeleteConnectCluster(DeleteConnectClusterRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Deletes a single Connect cluster.

Parameters
Name	Description
`request`	`DeleteConnectClusterRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`Operation`	The response received from the server.

DeleteConnectClusterAsync(DeleteConnectClusterRequest, CallOptions)

public virtual AsyncUnaryCall<Operation> DeleteConnectClusterAsync(DeleteConnectClusterRequest request, CallOptions options)

Deletes a single Connect cluster.

Parameters
Name	Description
`request`	`DeleteConnectClusterRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallOperation`	The call object.

DeleteConnectClusterAsync(DeleteConnectClusterRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<Operation> DeleteConnectClusterAsync(DeleteConnectClusterRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Deletes a single Connect cluster.

Parameters
Name	Description
`request`	`DeleteConnectClusterRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallOperation`	The call object.

DeleteConnector(DeleteConnectorRequest, CallOptions)

public virtual Empty DeleteConnector(DeleteConnectorRequest request, CallOptions options)

Deletes a connector.

Parameters
Name	Description
`request`	`DeleteConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`Empty`	The response received from the server.

DeleteConnector(DeleteConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual Empty DeleteConnector(DeleteConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Deletes a connector.

Parameters
Name	Description
`request`	`DeleteConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`Empty`	The response received from the server.

DeleteConnectorAsync(DeleteConnectorRequest, CallOptions)

public virtual AsyncUnaryCall<Empty> DeleteConnectorAsync(DeleteConnectorRequest request, CallOptions options)

Deletes a connector.

Parameters
Name	Description
`request`	`DeleteConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallEmpty`	The call object.

DeleteConnectorAsync(DeleteConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<Empty> DeleteConnectorAsync(DeleteConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Deletes a connector.

Parameters
Name	Description
`request`	`DeleteConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallEmpty`	The call object.

GetConnectCluster(GetConnectClusterRequest, CallOptions)

public virtual ConnectCluster GetConnectCluster(GetConnectClusterRequest request, CallOptions options)

Returns the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`GetConnectClusterRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`ConnectCluster`	The response received from the server.

GetConnectCluster(GetConnectClusterRequest, Metadata, DateTime?, CancellationToken)

public virtual ConnectCluster GetConnectCluster(GetConnectClusterRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Returns the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`GetConnectClusterRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`ConnectCluster`	The response received from the server.

GetConnectClusterAsync(GetConnectClusterRequest, CallOptions)

public virtual AsyncUnaryCall<ConnectCluster> GetConnectClusterAsync(GetConnectClusterRequest request, CallOptions options)

Returns the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`GetConnectClusterRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallConnectCluster`	The call object.

GetConnectClusterAsync(GetConnectClusterRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<ConnectCluster> GetConnectClusterAsync(GetConnectClusterRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Returns the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`GetConnectClusterRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallConnectCluster`	The call object.

GetConnector(GetConnectorRequest, CallOptions)

public virtual Connector GetConnector(GetConnectorRequest request, CallOptions options)

Returns the properties of a single connector.

Parameters
Name	Description
`request`	`GetConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`Connector`	The response received from the server.

GetConnector(GetConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual Connector GetConnector(GetConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Returns the properties of a single connector.

Parameters
Name	Description
`request`	`GetConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`Connector`	The response received from the server.

GetConnectorAsync(GetConnectorRequest, CallOptions)

public virtual AsyncUnaryCall<Connector> GetConnectorAsync(GetConnectorRequest request, CallOptions options)

Returns the properties of a single connector.

Parameters
Name	Description
`request`	`GetConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallConnector`	The call object.

GetConnectorAsync(GetConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<Connector> GetConnectorAsync(GetConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Returns the properties of a single connector.

Parameters
Name	Description
`request`	`GetConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallConnector`	The call object.

ListConnectClusters(ListConnectClustersRequest, CallOptions)

public virtual ListConnectClustersResponse ListConnectClusters(ListConnectClustersRequest request, CallOptions options)

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

Parameters
Name	Description
`request`	`ListConnectClustersRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`ListConnectClustersResponse`	The response received from the server.

ListConnectClusters(ListConnectClustersRequest, Metadata, DateTime?, CancellationToken)

public virtual ListConnectClustersResponse ListConnectClusters(ListConnectClustersRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

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

Parameters
Name	Description
`request`	`ListConnectClustersRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`ListConnectClustersResponse`	The response received from the server.

ListConnectClustersAsync(ListConnectClustersRequest, CallOptions)

public virtual AsyncUnaryCall<ListConnectClustersResponse> ListConnectClustersAsync(ListConnectClustersRequest request, CallOptions options)

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

Parameters
Name	Description
`request`	`ListConnectClustersRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallListConnectClustersResponse`	The call object.

ListConnectClustersAsync(ListConnectClustersRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<ListConnectClustersResponse> ListConnectClustersAsync(ListConnectClustersRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

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

Parameters
Name	Description
`request`	`ListConnectClustersRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallListConnectClustersResponse`	The call object.

ListConnectors(ListConnectorsRequest, CallOptions)

public virtual ListConnectorsResponse ListConnectors(ListConnectorsRequest request, CallOptions options)

Lists the connectors in a given Connect cluster.

Parameters
Name	Description
`request`	`ListConnectorsRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`ListConnectorsResponse`	The response received from the server.

ListConnectors(ListConnectorsRequest, Metadata, DateTime?, CancellationToken)

public virtual ListConnectorsResponse ListConnectors(ListConnectorsRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Lists the connectors in a given Connect cluster.

Parameters
Name	Description
`request`	`ListConnectorsRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`ListConnectorsResponse`	The response received from the server.

ListConnectorsAsync(ListConnectorsRequest, CallOptions)

public virtual AsyncUnaryCall<ListConnectorsResponse> ListConnectorsAsync(ListConnectorsRequest request, CallOptions options)

Lists the connectors in a given Connect cluster.

Parameters
Name	Description
`request`	`ListConnectorsRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallListConnectorsResponse`	The call object.

ListConnectorsAsync(ListConnectorsRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<ListConnectorsResponse> ListConnectorsAsync(ListConnectorsRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Lists the connectors in a given Connect cluster.

Parameters
Name	Description
`request`	`ListConnectorsRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallListConnectorsResponse`	The call object.

NewInstance(ClientBaseConfiguration)

protected override ManagedKafkaConnect.ManagedKafkaConnectClient NewInstance(ClientBase.ClientBaseConfiguration configuration)

Creates a new instance of client from given ClientBaseConfiguration.

Parameter
Name	Description
`configuration`	`ClientBaseClientBaseConfiguration`

Returns
Type	Description
`ManagedKafkaConnectManagedKafkaConnectClient`

Overrides

Grpc.Core.ClientBase<Google.Cloud.ManagedKafka.V1.ManagedKafkaConnect.ManagedKafkaConnectClient>.NewInstance(Grpc.Core.ClientBase.ClientBaseConfiguration)

PauseConnector(PauseConnectorRequest, CallOptions)

public virtual PauseConnectorResponse PauseConnector(PauseConnectorRequest request, CallOptions options)

Pauses the connector and its tasks.

Parameters
Name	Description
`request`	`PauseConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`PauseConnectorResponse`	The response received from the server.

PauseConnector(PauseConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual PauseConnectorResponse PauseConnector(PauseConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Pauses the connector and its tasks.

Parameters
Name	Description
`request`	`PauseConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`PauseConnectorResponse`	The response received from the server.

PauseConnectorAsync(PauseConnectorRequest, CallOptions)

public virtual AsyncUnaryCall<PauseConnectorResponse> PauseConnectorAsync(PauseConnectorRequest request, CallOptions options)

Pauses the connector and its tasks.

Parameters
Name	Description
`request`	`PauseConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallPauseConnectorResponse`	The call object.

PauseConnectorAsync(PauseConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<PauseConnectorResponse> PauseConnectorAsync(PauseConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Pauses the connector and its tasks.

Parameters
Name	Description
`request`	`PauseConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallPauseConnectorResponse`	The call object.

RestartConnector(RestartConnectorRequest, CallOptions)

public virtual RestartConnectorResponse RestartConnector(RestartConnectorRequest request, CallOptions options)

Restarts the connector.

Parameters
Name	Description
`request`	`RestartConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`RestartConnectorResponse`	The response received from the server.

RestartConnector(RestartConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual RestartConnectorResponse RestartConnector(RestartConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Restarts the connector.

Parameters
Name	Description
`request`	`RestartConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`RestartConnectorResponse`	The response received from the server.

RestartConnectorAsync(RestartConnectorRequest, CallOptions)

public virtual AsyncUnaryCall<RestartConnectorResponse> RestartConnectorAsync(RestartConnectorRequest request, CallOptions options)

Restarts the connector.

Parameters
Name	Description
`request`	`RestartConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallRestartConnectorResponse`	The call object.

RestartConnectorAsync(RestartConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<RestartConnectorResponse> RestartConnectorAsync(RestartConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Restarts the connector.

Parameters
Name	Description
`request`	`RestartConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallRestartConnectorResponse`	The call object.

ResumeConnector(ResumeConnectorRequest, CallOptions)

public virtual ResumeConnectorResponse ResumeConnector(ResumeConnectorRequest request, CallOptions options)

Resumes the connector and its tasks.

Parameters
Name	Description
`request`	`ResumeConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`ResumeConnectorResponse`	The response received from the server.

ResumeConnector(ResumeConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual ResumeConnectorResponse ResumeConnector(ResumeConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Resumes the connector and its tasks.

Parameters
Name	Description
`request`	`ResumeConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`ResumeConnectorResponse`	The response received from the server.

ResumeConnectorAsync(ResumeConnectorRequest, CallOptions)

public virtual AsyncUnaryCall<ResumeConnectorResponse> ResumeConnectorAsync(ResumeConnectorRequest request, CallOptions options)

Resumes the connector and its tasks.

Parameters
Name	Description
`request`	`ResumeConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallResumeConnectorResponse`	The call object.

ResumeConnectorAsync(ResumeConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<ResumeConnectorResponse> ResumeConnectorAsync(ResumeConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Resumes the connector and its tasks.

Parameters
Name	Description
`request`	`ResumeConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallResumeConnectorResponse`	The call object.

StopConnector(StopConnectorRequest, CallOptions)

public virtual StopConnectorResponse StopConnector(StopConnectorRequest request, CallOptions options)

Stops the connector.

Parameters
Name	Description
`request`	`StopConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`StopConnectorResponse`	The response received from the server.

StopConnector(StopConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual StopConnectorResponse StopConnector(StopConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Stops the connector.

Parameters
Name	Description
`request`	`StopConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`StopConnectorResponse`	The response received from the server.

StopConnectorAsync(StopConnectorRequest, CallOptions)

public virtual AsyncUnaryCall<StopConnectorResponse> StopConnectorAsync(StopConnectorRequest request, CallOptions options)

Stops the connector.

Parameters
Name	Description
`request`	`StopConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallStopConnectorResponse`	The call object.

StopConnectorAsync(StopConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<StopConnectorResponse> StopConnectorAsync(StopConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Stops the connector.

Parameters
Name	Description
`request`	`StopConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallStopConnectorResponse`	The call object.

UpdateConnectCluster(UpdateConnectClusterRequest, CallOptions)

public virtual Operation UpdateConnectCluster(UpdateConnectClusterRequest request, CallOptions options)

Updates the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`UpdateConnectClusterRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`Operation`	The response received from the server.

UpdateConnectCluster(UpdateConnectClusterRequest, Metadata, DateTime?, CancellationToken)

public virtual Operation UpdateConnectCluster(UpdateConnectClusterRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Updates the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`UpdateConnectClusterRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`Operation`	The response received from the server.

UpdateConnectClusterAsync(UpdateConnectClusterRequest, CallOptions)

public virtual AsyncUnaryCall<Operation> UpdateConnectClusterAsync(UpdateConnectClusterRequest request, CallOptions options)

Updates the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`UpdateConnectClusterRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallOperation`	The call object.

UpdateConnectClusterAsync(UpdateConnectClusterRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<Operation> UpdateConnectClusterAsync(UpdateConnectClusterRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Updates the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`UpdateConnectClusterRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallOperation`	The call object.

UpdateConnector(UpdateConnectorRequest, CallOptions)

public virtual Connector UpdateConnector(UpdateConnectorRequest request, CallOptions options)

Updates the properties of a connector.

Parameters
Name	Description
`request`	`UpdateConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`Connector`	The response received from the server.

UpdateConnector(UpdateConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual Connector UpdateConnector(UpdateConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Updates the properties of a connector.

Parameters
Name	Description
`request`	`UpdateConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`Connector`	The response received from the server.

UpdateConnectorAsync(UpdateConnectorRequest, CallOptions)

public virtual AsyncUnaryCall<Connector> UpdateConnectorAsync(UpdateConnectorRequest request, CallOptions options)

Updates the properties of a connector.

Parameters
Name	Description
`request`	`UpdateConnectorRequest` The request to send to the server.
`options`	`CallOptions` The options for the call.

Returns
Type	Description
`AsyncUnaryCallConnector`	The call object.

UpdateConnectorAsync(UpdateConnectorRequest, Metadata, DateTime?, CancellationToken)

public virtual AsyncUnaryCall<Connector> UpdateConnectorAsync(UpdateConnectorRequest request, Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default)

Updates the properties of a connector.

Parameters
Name	Description
`request`	`UpdateConnectorRequest` The request to send to the server.
`headers`	`Metadata` The initial metadata to send with the call. This parameter is optional.
`deadline`	`System.DateTime` An optional deadline for the call. The call will be cancelled if deadline is hit.
`cancellationToken`	`CancellationToken` An optional token for canceling the call.

Returns
Type	Description
`AsyncUnaryCallConnector`	The call object.

Managed Service for Apache Kafka API v1 API - Class ManagedKafkaConnect.ManagedKafkaConnectClient (1.0.0-beta05) Stay organized with collections Save and categorize content based on your preferences.

Inheritance

Inherited Members

Namespace

Assembly

Constructors

ManagedKafkaConnectClient()

ManagedKafkaConnectClient(CallInvoker)

ManagedKafkaConnectClient(ChannelBase)

ManagedKafkaConnectClient(ClientBaseConfiguration)

Methods

CreateConnectCluster(CreateConnectClusterRequest, CallOptions)

CreateConnectCluster(CreateConnectClusterRequest, Metadata, DateTime?, CancellationToken)

CreateConnectClusterAsync(CreateConnectClusterRequest, CallOptions)

CreateConnectClusterAsync(CreateConnectClusterRequest, Metadata, DateTime?, CancellationToken)

CreateConnector(CreateConnectorRequest, CallOptions)

CreateConnector(CreateConnectorRequest, Metadata, DateTime?, CancellationToken)

CreateConnectorAsync(CreateConnectorRequest, CallOptions)

CreateConnectorAsync(CreateConnectorRequest, Metadata, DateTime?, CancellationToken)

CreateLocationsClient()

CreateOperationsClient()

DeleteConnectCluster(DeleteConnectClusterRequest, CallOptions)

DeleteConnectCluster(DeleteConnectClusterRequest, Metadata, DateTime?, CancellationToken)

DeleteConnectClusterAsync(DeleteConnectClusterRequest, CallOptions)

DeleteConnectClusterAsync(DeleteConnectClusterRequest, Metadata, DateTime?, CancellationToken)

DeleteConnector(DeleteConnectorRequest, CallOptions)

DeleteConnector(DeleteConnectorRequest, Metadata, DateTime?, CancellationToken)

DeleteConnectorAsync(DeleteConnectorRequest, CallOptions)

DeleteConnectorAsync(DeleteConnectorRequest, Metadata, DateTime?, CancellationToken)

GetConnectCluster(GetConnectClusterRequest, CallOptions)

GetConnectCluster(GetConnectClusterRequest, Metadata, DateTime?, CancellationToken)

GetConnectClusterAsync(GetConnectClusterRequest, CallOptions)

GetConnectClusterAsync(GetConnectClusterRequest, Metadata, DateTime?, CancellationToken)

GetConnector(GetConnectorRequest, CallOptions)

GetConnector(GetConnectorRequest, Metadata, DateTime?, CancellationToken)

GetConnectorAsync(GetConnectorRequest, CallOptions)

GetConnectorAsync(GetConnectorRequest, Metadata, DateTime?, CancellationToken)

ListConnectClusters(ListConnectClustersRequest, CallOptions)

ListConnectClusters(ListConnectClustersRequest, Metadata, DateTime?, CancellationToken)

ListConnectClustersAsync(ListConnectClustersRequest, CallOptions)

ListConnectClustersAsync(ListConnectClustersRequest, Metadata, DateTime?, CancellationToken)

ListConnectors(ListConnectorsRequest, CallOptions)

ListConnectors(ListConnectorsRequest, Metadata, DateTime?, CancellationToken)

ListConnectorsAsync(ListConnectorsRequest, CallOptions)

ListConnectorsAsync(ListConnectorsRequest, Metadata, DateTime?, CancellationToken)

NewInstance(ClientBaseConfiguration)

PauseConnector(PauseConnectorRequest, CallOptions)

PauseConnector(PauseConnectorRequest, Metadata, DateTime?, CancellationToken)

PauseConnectorAsync(PauseConnectorRequest, CallOptions)

PauseConnectorAsync(PauseConnectorRequest, Metadata, DateTime?, CancellationToken)

RestartConnector(RestartConnectorRequest, CallOptions)

RestartConnector(RestartConnectorRequest, Metadata, DateTime?, CancellationToken)

RestartConnectorAsync(RestartConnectorRequest, CallOptions)

RestartConnectorAsync(RestartConnectorRequest, Metadata, DateTime?, CancellationToken)

ResumeConnector(ResumeConnectorRequest, CallOptions)

ResumeConnector(ResumeConnectorRequest, Metadata, DateTime?, CancellationToken)

ResumeConnectorAsync(ResumeConnectorRequest, CallOptions)

ResumeConnectorAsync(ResumeConnectorRequest, Metadata, DateTime?, CancellationToken)

StopConnector(StopConnectorRequest, CallOptions)

StopConnector(StopConnectorRequest, Metadata, DateTime?, CancellationToken)

StopConnectorAsync(StopConnectorRequest, CallOptions)

StopConnectorAsync(StopConnectorRequest, Metadata, DateTime?, CancellationToken)

UpdateConnectCluster(UpdateConnectClusterRequest, CallOptions)

UpdateConnectCluster(UpdateConnectClusterRequest, Metadata, DateTime?, CancellationToken)

UpdateConnectClusterAsync(UpdateConnectClusterRequest, CallOptions)

UpdateConnectClusterAsync(UpdateConnectClusterRequest, Metadata, DateTime?, CancellationToken)

UpdateConnector(UpdateConnectorRequest, CallOptions)

UpdateConnector(UpdateConnectorRequest, Metadata, DateTime?, CancellationToken)

UpdateConnectorAsync(UpdateConnectorRequest, CallOptions)

UpdateConnectorAsync(UpdateConnectorRequest, Metadata, DateTime?, CancellationToken)

Managed Service for Apache Kafka API v1 API - Class ManagedKafkaConnect.ManagedKafkaConnectClient (1.0.0-beta05)
Stay organized with collections Save and categorize content based on your preferences.