Google Cloud Managed Kafka V1 Client - Class Connector (0.4.0)
Stay organized with collections Save and categorize content based on your preferences.

Reference documentation and code samples for the Google Cloud Managed Kafka V1 Client class Connector.

A Kafka Connect connector in a given ConnectCluster.

Generated from protobuf message google.cloud.managedkafka.v1.Connector

Namespace

Google \ Cloud \ ManagedKafka \ V1

Methods

__construct

Constructor.

Parameters
Name	Description
`data`	`array` Optional. Data for populating the Message object.
`↳ task_restart_policy`	`TaskRetryPolicy` Optional. Restarts the individual tasks of a Connector.
`↳ name`	`string` Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}
`↳ configs`	`array\|Google\Protobuf\Internal\MapField` Optional. Connector config as keys/values. The keys of the map are connector property names, for example: `connector.class`, `tasks.max`, `key.converter`.
`↳ state`	`int` Output only. The current state of the connector.

getTaskRestartPolicy

Optional. Restarts the individual tasks of a Connector.

Returns
Type	Description
`TaskRetryPolicy\|null`

hasTaskRestartPolicy

setTaskRestartPolicy

Optional. Restarts the individual tasks of a Connector.

Parameter
Name	Description
`var`	`TaskRetryPolicy`

Returns
Type	Description
`$this`

getName

Identifier. The name of the connector.

Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}

Returns
Type	Description
`string`

setName

Identifier. The name of the connector.

Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}

Parameter
Name	Description
`var`	`string`

Returns
Type	Description
`$this`

getConfigs

Optional. Connector config as keys/values.

The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

Returns
Type	Description
`Google\Protobuf\Internal\MapField`

setConfigs