Managed Service for Apache Kafka V1 API - Class Google::Cloud::ManagedKafka::V1::Connector (v1.6.0)

Reference documentation and code samples for the Managed Service for Apache Kafka V1 API class Google::Cloud::ManagedKafka::V1::Connector.

A Kafka Connect connector in a given ConnectCluster.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#configs

def configs() -> ::Google::Protobuf::Map{::String => ::String}
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

#configs=

def configs=(value) -> ::Google::Protobuf::Map{::String => ::String}
Parameter
  • value (::Google::Protobuf::Map{::String => ::String}) — Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

#name

def name() -> ::String
Returns
  • (::String) — Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}

#name=

def name=(value) -> ::String
Parameter
  • value (::String) — Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}
Returns
  • (::String) — Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}

#state

def state() -> ::Google::Cloud::ManagedKafka::V1::Connector::State
Returns

#task_restart_policy

def task_restart_policy() -> ::Google::Cloud::ManagedKafka::V1::TaskRetryPolicy
Returns

#task_restart_policy=

def task_restart_policy=(value) -> ::Google::Cloud::ManagedKafka::V1::TaskRetryPolicy
Parameter
Returns