public interface ConnectorOrBuilder extends MessageOrBuilderImplements
MessageOrBuilderMethods
containsConfigs(String key)
public abstract boolean containsConfigs(String key) Optional. Connector config as keys/values.
The keys of the map are connector property names, for example:
connector.class, tasks.max, key.converter.
map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];
| Parameter | |
|---|---|
| Name | Description |
key |
String |
| Returns | |
|---|---|
| Type | Description |
boolean |
|
getConfigs() (deprecated)
public abstract Map<String,String> getConfigs()Use #getConfigsMap() instead.
| Returns | |
|---|---|
| Type | Description |
Map<String,String> |
|
getConfigsCount()
public abstract int getConfigsCount() Optional. Connector config as keys/values.
The keys of the map are connector property names, for example:
connector.class, tasks.max, key.converter.
map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
int |
|
getConfigsMap()
public abstract Map<String,String> getConfigsMap() Optional. Connector config as keys/values.
The keys of the map are connector property names, for example:
connector.class, tasks.max, key.converter.
map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
Map<String,String> |
|
getConfigsOrDefault(String key, String defaultValue)
public abstract String getConfigsOrDefault(String key, String defaultValue) Optional. Connector config as keys/values.
The keys of the map are connector property names, for example:
connector.class, tasks.max, key.converter.
map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];
| Parameters | |
|---|---|
| Name | Description |
key |
String |
defaultValue |
String |
| Returns | |
|---|---|
| Type | Description |
String |
|
getConfigsOrThrow(String key)
public abstract String getConfigsOrThrow(String key) Optional. Connector config as keys/values.
The keys of the map are connector property names, for example:
connector.class, tasks.max, key.converter.
map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];
| Parameter | |
|---|---|
| Name | Description |
key |
String |
| Returns | |
|---|---|
| Type | Description |
String |
|
getName()
public abstract String getName()Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}
string name = 1 [(.google.api.field_behavior) = IDENTIFIER];
| Returns | |
|---|---|
| Type | Description |
String |
The name. |
getNameBytes()
public abstract ByteString getNameBytes()Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}
string name = 1 [(.google.api.field_behavior) = IDENTIFIER];
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for name. |
getRestartPolicyCase()
public abstract Connector.RestartPolicyCase getRestartPolicyCase()| Returns | |
|---|---|
| Type | Description |
Connector.RestartPolicyCase |
|
getState()
public abstract Connector.State getState()Output only. The current state of the connector.
.google.cloud.managedkafka.v1.Connector.State state = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Returns | |
|---|---|
| Type | Description |
Connector.State |
The state. |
getStateValue()
public abstract int getStateValue()Output only. The current state of the connector.
.google.cloud.managedkafka.v1.Connector.State state = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];
| Returns | |
|---|---|
| Type | Description |
int |
The enum numeric value on the wire for state. |
getTaskRestartPolicy()
public abstract TaskRetryPolicy getTaskRestartPolicy()Optional. Restarts the individual tasks of a Connector.
.google.cloud.managedkafka.v1.TaskRetryPolicy task_restart_policy = 4 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
TaskRetryPolicy |
The taskRestartPolicy. |
getTaskRestartPolicyOrBuilder()
public abstract TaskRetryPolicyOrBuilder getTaskRestartPolicyOrBuilder()Optional. Restarts the individual tasks of a Connector.
.google.cloud.managedkafka.v1.TaskRetryPolicy task_restart_policy = 4 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
TaskRetryPolicyOrBuilder |
|
hasTaskRestartPolicy()
public abstract boolean hasTaskRestartPolicy()Optional. Restarts the individual tasks of a Connector.
.google.cloud.managedkafka.v1.TaskRetryPolicy task_restart_policy = 4 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
boolean |
Whether the taskRestartPolicy field is set. |