Class Connector (0.28.0)
0.43.0 (latest)
0.41.0
0.39.0
0.38.0
0.37.0
0.36.0
0.34.0
0.32.0
0.31.0
0.30.0
0.29.0
0.28.0
0.26.0
0.24.0
0.23.0
0.20.0
0.19.0
0.18.0
0.16.1
0.15.0
0.14.0
0.13.0
0.12.0
0.11.0
0.10.0
0.9.0
0.8.0
0.7.0
0.5.0
0.4.0
0.3.0
0.2.0
0.1.0
public final class Connector extends GeneratedMessageV3 implements ConnectorOrBuilder
A Kafka Connect connector in a given ConnectCluster.
Protobuf type google.cloud.managedkafka.v1.Connector
Inherited Members
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)
com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
Static Fields
CONFIGS_FIELD_NUMBER
public static final int CONFIGS_FIELD_NUMBER
Field Value
Type Description
int
NAME_FIELD_NUMBER
public static final int NAME_FIELD_NUMBER
Field Value
Type Description
int
STATE_FIELD_NUMBER
public static final int STATE_FIELD_NUMBER
Field Value
Type Description
int
TASK_RESTART_POLICY_FIELD_NUMBER
public static final int TASK_RESTART_POLICY_FIELD_NUMBER
Field Value
Type Description
int
Static Methods
getDefaultInstance()
public static Connector getDefaultInstance ()
getDescriptor()
public static final Descriptors . Descriptor getDescriptor ()
newBuilder()
public static Connector . Builder newBuilder ()
newBuilder(Connector prototype)
public static Connector . Builder newBuilder ( Connector prototype )
Parameter
Name Description
prototypeConnector
public static Connector parseDelimitedFrom ( InputStream input )
public static Connector parseDelimitedFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(byte[] data)
public static Connector parseFrom ( byte [] data )
Parameter
Name Description
databyte []
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static Connector parseFrom ( byte [] data , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteString data)
public static Connector parseFrom ( ByteString data )
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static Connector parseFrom ( ByteString data , ExtensionRegistryLite extensionRegistry )
public static Connector parseFrom ( CodedInputStream input )
public static Connector parseFrom ( CodedInputStream input , ExtensionRegistryLite extensionRegistry )
public static Connector parseFrom ( InputStream input )
public static Connector parseFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteBuffer data)
public static Connector parseFrom ( ByteBuffer data )
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static Connector parseFrom ( ByteBuffer data , ExtensionRegistryLite extensionRegistry )
parser()
public static Parser<Connector> parser ()
Methods
containsConfigs(String key)
public 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
keyString
equals(Object obj)
public boolean equals ( Object obj )
Parameter
Name Description
objObject
Overrides
getConfigs() (deprecated)
public Map<String , String > getConfigs ()
getConfigsCount()
public 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 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];
getConfigsOrDefault(String key, String defaultValue)
public 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];
Returns
Type Description
String
getConfigsOrThrow(String key)
public 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
keyString
Returns
Type Description
String
getDefaultInstanceForType()
public Connector getDefaultInstanceForType ()
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 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.
getParserForType()
public Parser<Connector> getParserForType ()
Overrides
getRestartPolicyCase()
public Connector . RestartPolicyCase getRestartPolicyCase ()
getSerializedSize()
public int getSerializedSize ()
Returns
Type Description
int
Overrides
getState()
public 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];
getStateValue()
public 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 TaskRetryPolicy getTaskRestartPolicy ()
Optional. Restarts the individual tasks of a Connector.
.google.cloud.managedkafka.v1.TaskRetryPolicy task_restart_policy = 4 [(.google.api.field_behavior) = OPTIONAL];
getTaskRestartPolicyOrBuilder()
public TaskRetryPolicyOrBuilder getTaskRestartPolicyOrBuilder ()
Optional. Restarts the individual tasks of a Connector.
.google.cloud.managedkafka.v1.TaskRetryPolicy task_restart_policy = 4 [(.google.api.field_behavior) = OPTIONAL];
hasTaskRestartPolicy()
public 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.
hashCode()
Returns
Type Description
int
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3 . FieldAccessorTable internalGetFieldAccessorTable ()
Overrides
internalGetMapFieldReflection(int number)
protected MapFieldReflectionAccessor internalGetMapFieldReflection ( int number )
Parameter
Name Description
numberint
Returns
Type Description
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
isInitialized()
public final boolean isInitialized ()
Overrides
newBuilderForType()
public Connector . Builder newBuilderForType ()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected Connector . Builder newBuilderForType ( GeneratedMessageV3 . BuilderParent parent )
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance ( GeneratedMessageV3 . UnusedPrivateParameter unused )
Returns
Type Description
Object
Overrides
toBuilder()
public Connector . Builder toBuilder ()
writeTo(CodedOutputStream output)
public void writeTo ( CodedOutputStream output )
Overrides
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2026-03-14 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2026-03-14 UTC."],[],[]]
