public sealed class Connector : IMessage<Connector>, IEquatable<Connector>, IDeepCloneable<Connector>, IBufferMessage, IMessage
Reference documentation and code samples for the Managed Service for Apache Kafka API v1 API class Connector.
A Kafka Connect connector in a given ConnectCluster.
Implements
IMessageConnector, IEquatableConnector, IDeepCloneableConnector, IBufferMessage, IMessageNamespace
Google.Cloud.ManagedKafka.V1Assembly
Google.Cloud.ManagedKafka.V1.dll
Constructors
Connector()
public Connector()
Connector(Connector)
public Connector(Connector other)
Parameter | |
---|---|
Name | Description |
other |
Connector |
Properties
Configs
public MapField<string, string> Configs { get; }
Optional. Connector config as keys/values.
The keys of the map are connector property names, for example:
connector.class
, tasks.max
, key.converter
.
Property Value | |
---|---|
Type | Description |
MapFieldstringstring |
ConnectorName
public ConnectorName ConnectorName { get; set; }
ConnectorName-typed view over the Name resource name property.
Property Value | |
---|---|
Type | Description |
ConnectorName |
Name
public string Name { get; set; }
Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}
Property Value | |
---|---|
Type | Description |
string |
RestartPolicyCase
public Connector.RestartPolicyOneofCase RestartPolicyCase { get; }
Property Value | |
---|---|
Type | Description |
ConnectorRestartPolicyOneofCase |
State
public Connector.Types.State State { get; set; }
Output only. The current state of the connector.
Property Value | |
---|---|
Type | Description |
ConnectorTypesState |
TaskRestartPolicy
public TaskRetryPolicy TaskRestartPolicy { get; set; }
Optional. Restarts the individual tasks of a Connector.
Property Value | |
---|---|
Type | Description |
TaskRetryPolicy |