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

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

An Apache Kafka Connect cluster deployed in a location.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#capacity_config

def capacity_config() -> ::Google::Cloud::ManagedKafka::V1::CapacityConfig
Returns

#capacity_config=

def capacity_config=(value) -> ::Google::Cloud::ManagedKafka::V1::CapacityConfig
Parameter
Returns

#config

def config() -> ::Google::Protobuf::Map{::String => ::String}
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Optional. Configurations for the worker that are overridden from the defaults. The key of the map is a Kafka Connect worker property name, for example: exactly.once.source.support.

#config=

def config=(value) -> ::Google::Protobuf::Map{::String => ::String}
Parameter
  • value (::Google::Protobuf::Map{::String => ::String}) — Optional. Configurations for the worker that are overridden from the defaults. The key of the map is a Kafka Connect worker property name, for example: exactly.once.source.support.
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Optional. Configurations for the worker that are overridden from the defaults. The key of the map is a Kafka Connect worker property name, for example: exactly.once.source.support.

#create_time

def create_time() -> ::Google::Protobuf::Timestamp
Returns

#gcp_config

def gcp_config() -> ::Google::Cloud::ManagedKafka::V1::ConnectGcpConfig
Returns

#gcp_config=

def gcp_config=(value) -> ::Google::Cloud::ManagedKafka::V1::ConnectGcpConfig
Parameter
Returns

#kafka_cluster

def kafka_cluster() -> ::String
Returns
  • (::String) — Required. Immutable. The name of the Kafka cluster this Kafka Connect cluster is attached to. Structured like: projects/{project}/locations/{location}/clusters/{cluster}

#kafka_cluster=

def kafka_cluster=(value) -> ::String
Parameter
  • value (::String) — Required. Immutable. The name of the Kafka cluster this Kafka Connect cluster is attached to. Structured like: projects/{project}/locations/{location}/clusters/{cluster}
Returns
  • (::String) — Required. Immutable. The name of the Kafka cluster this Kafka Connect cluster is attached to. Structured like: projects/{project}/locations/{location}/clusters/{cluster}

#labels

def labels() -> ::Google::Protobuf::Map{::String => ::String}
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Optional. Labels as key value pairs.

#labels=

def labels=(value) -> ::Google::Protobuf::Map{::String => ::String}
Parameter
  • value (::Google::Protobuf::Map{::String => ::String}) — Optional. Labels as key value pairs.
Returns
  • (::Google::Protobuf::Map{::String => ::String}) — Optional. Labels as key value pairs.

#name

def name() -> ::String
Returns
  • (::String) — Identifier. The name of the Kafka Connect cluster. Structured like: projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}

#name=

def name=(value) -> ::String
Parameter
  • value (::String) — Identifier. The name of the Kafka Connect cluster. Structured like: projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}
Returns
  • (::String) — Identifier. The name of the Kafka Connect cluster. Structured like: projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}

#state

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

#update_time

def update_time() -> ::Google::Protobuf::Timestamp
Returns