ConnectCluster(mapping=None, *, ignore_unknown_fields=False, **kwargs)
An Apache Kafka Connect cluster deployed in a location.
.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
Attributes |
|
---|---|
Name | Description |
gcp_config |
google.cloud.managedkafka_v1.types.ConnectGcpConfig
Required. Configuration properties for a Kafka Connect cluster deployed to Google Cloud Platform. This field is a member of oneof _ platform_config .
|
name |
str
Identifier. The name of the Kafka Connect cluster. Structured like: projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id} |
kafka_cluster |
str
Required. Immutable. The name of the Kafka cluster this Kafka Connect cluster is attached to. Structured like: projects/{project}/locations/{location}/clusters/{cluster} |
create_time |
google.protobuf.timestamp_pb2.Timestamp
Output only. The time when the cluster was created. |
update_time |
google.protobuf.timestamp_pb2.Timestamp
Output only. The time when the cluster was last updated. |
labels |
MutableMapping[str, str]
Optional. Labels as key value pairs. |
capacity_config |
google.cloud.managedkafka_v1.types.CapacityConfig
Required. Capacity configuration for the Kafka Connect cluster. |
state |
google.cloud.managedkafka_v1.types.ConnectCluster.State
Output only. The current state of the cluster. |
config |
MutableMapping[str, str]
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 .
|
Classes
ConfigEntry
ConfigEntry(mapping=None, *, ignore_unknown_fields=False, **kwargs)
The abstract base class for a message.
Parameters | |
---|---|
Name | Description |
kwargs |
dict
Keys and values corresponding to the fields of the message. |
mapping |
Union[dict,
A dictionary or message to be used to determine the values for this message. |
ignore_unknown_fields |
Optional(bool)
If True, do not raise errors for unknown fields. Only applied if |
LabelsEntry
LabelsEntry(mapping=None, *, ignore_unknown_fields=False, **kwargs)
The abstract base class for a message.
Parameters | |
---|---|
Name | Description |
kwargs |
dict
Keys and values corresponding to the fields of the message. |
mapping |
Union[dict,
A dictionary or message to be used to determine the values for this message. |
ignore_unknown_fields |
Optional(bool)
If True, do not raise errors for unknown fields. Only applied if |
State
State(value)
The state of the cluster.