Package com.google.cloud.managedkafka.v1

Class ConnectCluster.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<ConnectCluster.Builder>
com.google.cloud.managedkafka.v1.ConnectCluster.Builder
All Implemented Interfaces:
ConnectClusterOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
ConnectCluster
public static final class ConnectCluster.Builder extends com.google.protobuf.GeneratedMessage.Builder<ConnectCluster.Builder> implements ConnectClusterOrBuilder
 An Apache Kafka Connect cluster deployed in a location.
Protobuf type google.cloud.managedkafka.v1.ConnectCluster

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
      Overrides:
      internalGetMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<ConnectCluster.Builder>

    • internalGetMutableMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number)
      Overrides:
      internalGetMutableMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<ConnectCluster.Builder>

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<ConnectCluster.Builder>

    • clear

      public ConnectCluster.Builder clear()
      Specified by:
      clear in interface com.google.protobuf.Message.Builder
      Specified by:
      clear in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clear in class com.google.protobuf.GeneratedMessage.Builder<ConnectCluster.Builder>

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<ConnectCluster.Builder>

    • getDefaultInstanceForType

      public ConnectCluster getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

    • build

      public ConnectCluster build()
      Specified by:
      build in interface com.google.protobuf.Message.Builder
      Specified by:
      build in interface com.google.protobuf.MessageLite.Builder

    • buildPartial

      public ConnectCluster buildPartial()
      Specified by:
      buildPartial in interface com.google.protobuf.Message.Builder
      Specified by:
      buildPartial in interface com.google.protobuf.MessageLite.Builder

    • mergeFrom

      public ConnectCluster.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<ConnectCluster.Builder>

    • mergeFrom

      public ConnectCluster.Builder mergeFrom(ConnectCluster other)

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage.Builder<ConnectCluster.Builder>

    • mergeFrom

      public ConnectCluster.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<ConnectCluster.Builder>
      Throws:
      IOException

    • getPlatformConfigCase

      public ConnectCluster.PlatformConfigCase getPlatformConfigCase()
      Specified by:
      getPlatformConfigCase in interface ConnectClusterOrBuilder

    • clearPlatformConfig

      public ConnectCluster.Builder clearPlatformConfig()

    • hasGcpConfig

      public boolean hasGcpConfig()
       Required. Configuration properties for a Kafka Connect cluster deployed
 to Google Cloud Platform.
      .google.cloud.managedkafka.v1.ConnectGcpConfig gcp_config = 7 [(.google.api.field_behavior) = REQUIRED];
      Specified by:
      hasGcpConfig in interface ConnectClusterOrBuilder
      Returns:
      Whether the gcpConfig field is set.

    • getGcpConfig

      public ConnectGcpConfig getGcpConfig()
       Required. Configuration properties for a Kafka Connect cluster deployed
 to Google Cloud Platform.
      .google.cloud.managedkafka.v1.ConnectGcpConfig gcp_config = 7 [(.google.api.field_behavior) = REQUIRED];
      Specified by:
      getGcpConfig in interface ConnectClusterOrBuilder
      Returns:
      The gcpConfig.

    • setGcpConfig

      public ConnectCluster.Builder setGcpConfig(ConnectGcpConfig value)
       Required. Configuration properties for a Kafka Connect cluster deployed
 to Google Cloud Platform.
      .google.cloud.managedkafka.v1.ConnectGcpConfig gcp_config = 7 [(.google.api.field_behavior) = REQUIRED];

    • setGcpConfig

      public ConnectCluster.Builder setGcpConfig(ConnectGcpConfig.Builder builderForValue)
       Required. Configuration properties for a Kafka Connect cluster deployed
 to Google Cloud Platform.
      .google.cloud.managedkafka.v1.ConnectGcpConfig gcp_config = 7 [(.google.api.field_behavior) = REQUIRED];

    • mergeGcpConfig

      public ConnectCluster.Builder mergeGcpConfig(ConnectGcpConfig value)
       Required. Configuration properties for a Kafka Connect cluster deployed
 to Google Cloud Platform.
      .google.cloud.managedkafka.v1.ConnectGcpConfig gcp_config = 7 [(.google.api.field_behavior) = REQUIRED];

    • clearGcpConfig

      public ConnectCluster.Builder clearGcpConfig()
       Required. Configuration properties for a Kafka Connect cluster deployed
 to Google Cloud Platform.
      .google.cloud.managedkafka.v1.ConnectGcpConfig gcp_config = 7 [(.google.api.field_behavior) = REQUIRED];

    • getGcpConfigBuilder

      public ConnectGcpConfig.Builder getGcpConfigBuilder()
       Required. Configuration properties for a Kafka Connect cluster deployed
 to Google Cloud Platform.
      .google.cloud.managedkafka.v1.ConnectGcpConfig gcp_config = 7 [(.google.api.field_behavior) = REQUIRED];

    • getGcpConfigOrBuilder

      public ConnectGcpConfigOrBuilder getGcpConfigOrBuilder()
       Required. Configuration properties for a Kafka Connect cluster deployed
 to Google Cloud Platform.
      .google.cloud.managedkafka.v1.ConnectGcpConfig gcp_config = 7 [(.google.api.field_behavior) = REQUIRED];
      Specified by:
      getGcpConfigOrBuilder in interface ConnectClusterOrBuilder

    • getName

      public String getName()
       Identifier. The name of the Kafka Connect cluster. Structured like:
 projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}
      string name = 1 [(.google.api.field_behavior) = IDENTIFIER];
      Specified by:
      getName in interface ConnectClusterOrBuilder
      Returns:
      The name.

    • getNameBytes

      public com.google.protobuf.ByteString getNameBytes()
       Identifier. The name of the Kafka Connect cluster. Structured like:
 projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}
      string name = 1 [(.google.api.field_behavior) = IDENTIFIER];
      Specified by:
      getNameBytes in interface ConnectClusterOrBuilder
      Returns:
      The bytes for name.

    • setName

      public ConnectCluster.Builder setName(String value)
       Identifier. The name of the Kafka Connect cluster. Structured like:
 projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}
      string name = 1 [(.google.api.field_behavior) = IDENTIFIER];
      Parameters:
      value - The name to set.
      Returns:
      This builder for chaining.

    • clearName

      public ConnectCluster.Builder clearName()
       Identifier. The name of the Kafka Connect cluster. Structured like:
 projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}
      string name = 1 [(.google.api.field_behavior) = IDENTIFIER];
      Returns:
      This builder for chaining.

    • setNameBytes

      public ConnectCluster.Builder setNameBytes(com.google.protobuf.ByteString value)
       Identifier. The name of the Kafka Connect cluster. Structured like:
 projects/{project_number}/locations/{location}/connectClusters/{connect_cluster_id}
      string name = 1 [(.google.api.field_behavior) = IDENTIFIER];
      Parameters:
      value - The bytes for name to set.
      Returns:
      This builder for chaining.

    • getKafkaCluster

      public String getKafkaCluster()
       Required. Immutable. The name of the Kafka cluster this Kafka Connect
 cluster is attached to. Structured like:
 projects/{project}/locations/{location}/clusters/{cluster}
      string kafka_cluster = 2 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
      Specified by:
      getKafkaCluster in interface ConnectClusterOrBuilder
      Returns:
      The kafkaCluster.

    • getKafkaClusterBytes

      public com.google.protobuf.ByteString getKafkaClusterBytes()
       Required. Immutable. The name of the Kafka cluster this Kafka Connect
 cluster is attached to. Structured like:
 projects/{project}/locations/{location}/clusters/{cluster}
      string kafka_cluster = 2 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
      Specified by:
      getKafkaClusterBytes in interface ConnectClusterOrBuilder
      Returns:
      The bytes for kafkaCluster.

    • setKafkaCluster

      public ConnectCluster.Builder setKafkaCluster(String value)
       Required. Immutable. The name of the Kafka cluster this Kafka Connect
 cluster is attached to. Structured like:
 projects/{project}/locations/{location}/clusters/{cluster}
      string kafka_cluster = 2 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
      Parameters:
      value - The kafkaCluster to set.
      Returns:
      This builder for chaining.

    • clearKafkaCluster

      public ConnectCluster.Builder clearKafkaCluster()
       Required. Immutable. The name of the Kafka cluster this Kafka Connect
 cluster is attached to. Structured like:
 projects/{project}/locations/{location}/clusters/{cluster}
      string kafka_cluster = 2 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
      Returns:
      This builder for chaining.

    • setKafkaClusterBytes

      public ConnectCluster.Builder setKafkaClusterBytes(com.google.protobuf.ByteString value)
       Required. Immutable. The name of the Kafka cluster this Kafka Connect
 cluster is attached to. Structured like:
 projects/{project}/locations/{location}/clusters/{cluster}
      string kafka_cluster = 2 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
      Parameters:
      value - The bytes for kafkaCluster to set.
      Returns:
      This builder for chaining.

    • hasCreateTime

      public boolean hasCreateTime()
       Output only. The time when the cluster was created.
      .google.protobuf.Timestamp create_time = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      hasCreateTime in interface ConnectClusterOrBuilder
      Returns:
      Whether the createTime field is set.

    • getCreateTime

      public com.google.protobuf.Timestamp getCreateTime()
       Output only. The time when the cluster was created.
      .google.protobuf.Timestamp create_time = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getCreateTime in interface ConnectClusterOrBuilder
      Returns:
      The createTime.

    • setCreateTime

      public ConnectCluster.Builder setCreateTime(com.google.protobuf.Timestamp value)
       Output only. The time when the cluster was created.
      .google.protobuf.Timestamp create_time = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • setCreateTime

      public ConnectCluster.Builder setCreateTime(com.google.protobuf.Timestamp.Builder builderForValue)
       Output only. The time when the cluster was created.
      .google.protobuf.Timestamp create_time = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • mergeCreateTime

      public ConnectCluster.Builder mergeCreateTime(com.google.protobuf.Timestamp value)
       Output only. The time when the cluster was created.
      .google.protobuf.Timestamp create_time = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • clearCreateTime

      public ConnectCluster.Builder clearCreateTime()
       Output only. The time when the cluster was created.
      .google.protobuf.Timestamp create_time = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • getCreateTimeBuilder

      public com.google.protobuf.Timestamp.Builder getCreateTimeBuilder()
       Output only. The time when the cluster was created.
      .google.protobuf.Timestamp create_time = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • getCreateTimeOrBuilder

      public com.google.protobuf.TimestampOrBuilder getCreateTimeOrBuilder()
       Output only. The time when the cluster was created.
      .google.protobuf.Timestamp create_time = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getCreateTimeOrBuilder in interface ConnectClusterOrBuilder

    • hasUpdateTime

      public boolean hasUpdateTime()
       Output only. The time when the cluster was last updated.
      .google.protobuf.Timestamp update_time = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      hasUpdateTime in interface ConnectClusterOrBuilder
      Returns:
      Whether the updateTime field is set.

    • getUpdateTime

      public com.google.protobuf.Timestamp getUpdateTime()
       Output only. The time when the cluster was last updated.
      .google.protobuf.Timestamp update_time = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getUpdateTime in interface ConnectClusterOrBuilder
      Returns:
      The updateTime.

    • setUpdateTime

      public ConnectCluster.Builder setUpdateTime(com.google.protobuf.Timestamp value)
       Output only. The time when the cluster was last updated.
      .google.protobuf.Timestamp update_time = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • setUpdateTime

      public ConnectCluster.Builder setUpdateTime(com.google.protobuf.Timestamp.Builder builderForValue)
       Output only. The time when the cluster was last updated.
      .google.protobuf.Timestamp update_time = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • mergeUpdateTime

      public ConnectCluster.Builder mergeUpdateTime(com.google.protobuf.Timestamp value)
       Output only. The time when the cluster was last updated.
      .google.protobuf.Timestamp update_time = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • clearUpdateTime

      public ConnectCluster.Builder clearUpdateTime()
       Output only. The time when the cluster was last updated.
      .google.protobuf.Timestamp update_time = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • getUpdateTimeBuilder

      public com.google.protobuf.Timestamp.Builder getUpdateTimeBuilder()
       Output only. The time when the cluster was last updated.
      .google.protobuf.Timestamp update_time = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];

    • getUpdateTimeOrBuilder

      public com.google.protobuf.TimestampOrBuilder getUpdateTimeOrBuilder()
       Output only. The time when the cluster was last updated.
      .google.protobuf.Timestamp update_time = 4 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getUpdateTimeOrBuilder in interface ConnectClusterOrBuilder

    • getLabelsCount

      public int getLabelsCount()
      Description copied from interface: ConnectClusterOrBuilder
       Optional. Labels as key value pairs.
      map<string, string> labels = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getLabelsCount in interface ConnectClusterOrBuilder

    • containsLabels

      public boolean containsLabels(String key)
       Optional. Labels as key value pairs.
      map<string, string> labels = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      containsLabels in interface ConnectClusterOrBuilder

    • getLabels

      @Deprecated public Map<String,String> getLabels()
      Deprecated.
      Use getLabelsMap() instead.
      Specified by:
      getLabels in interface ConnectClusterOrBuilder

    • getLabelsMap

      public Map<String,String> getLabelsMap()
       Optional. Labels as key value pairs.
      map<string, string> labels = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getLabelsMap in interface ConnectClusterOrBuilder

    • getLabelsOrDefault

      public String getLabelsOrDefault(String key, String defaultValue)
       Optional. Labels as key value pairs.
      map<string, string> labels = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getLabelsOrDefault in interface ConnectClusterOrBuilder

    • getLabelsOrThrow

      public String getLabelsOrThrow(String key)
       Optional. Labels as key value pairs.
      map<string, string> labels = 5 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getLabelsOrThrow in interface ConnectClusterOrBuilder

    • clearLabels

      public ConnectCluster.Builder clearLabels()

    • removeLabels

      public ConnectCluster.Builder removeLabels(String key)
       Optional. Labels as key value pairs.
      map<string, string> labels = 5 [(.google.api.field_behavior) = OPTIONAL];

    • getMutableLabels

      @Deprecated public Map<String,String> getMutableLabels()
      Deprecated.
      Use alternate mutation accessors instead.

    • putLabels

      public ConnectCluster.Builder putLabels(String key, String value)
       Optional. Labels as key value pairs.
      map<string, string> labels = 5 [(.google.api.field_behavior) = OPTIONAL];

    • putAllLabels

      public ConnectCluster.Builder putAllLabels(Map<String,String> values)
       Optional. Labels as key value pairs.
      map<string, string> labels = 5 [(.google.api.field_behavior) = OPTIONAL];

    • hasCapacityConfig

      public boolean hasCapacityConfig()
       Required. Capacity configuration for the Kafka Connect cluster.
      .google.cloud.managedkafka.v1.CapacityConfig capacity_config = 6 [(.google.api.field_behavior) = REQUIRED];
      Specified by:
      hasCapacityConfig in interface ConnectClusterOrBuilder
      Returns:
      Whether the capacityConfig field is set.

    • getCapacityConfig

      public CapacityConfig getCapacityConfig()
       Required. Capacity configuration for the Kafka Connect cluster.
      .google.cloud.managedkafka.v1.CapacityConfig capacity_config = 6 [(.google.api.field_behavior) = REQUIRED];
      Specified by:
      getCapacityConfig in interface ConnectClusterOrBuilder
      Returns:
      The capacityConfig.

    • setCapacityConfig

      public ConnectCluster.Builder setCapacityConfig(CapacityConfig value)
       Required. Capacity configuration for the Kafka Connect cluster.
      .google.cloud.managedkafka.v1.CapacityConfig capacity_config = 6 [(.google.api.field_behavior) = REQUIRED];

    • setCapacityConfig

      public ConnectCluster.Builder setCapacityConfig(CapacityConfig.Builder builderForValue)
       Required. Capacity configuration for the Kafka Connect cluster.
      .google.cloud.managedkafka.v1.CapacityConfig capacity_config = 6 [(.google.api.field_behavior) = REQUIRED];

    • mergeCapacityConfig

      public ConnectCluster.Builder mergeCapacityConfig(CapacityConfig value)
       Required. Capacity configuration for the Kafka Connect cluster.
      .google.cloud.managedkafka.v1.CapacityConfig capacity_config = 6 [(.google.api.field_behavior) = REQUIRED];

    • clearCapacityConfig

      public ConnectCluster.Builder clearCapacityConfig()
       Required. Capacity configuration for the Kafka Connect cluster.
      .google.cloud.managedkafka.v1.CapacityConfig capacity_config = 6 [(.google.api.field_behavior) = REQUIRED];

    • getCapacityConfigBuilder

      public CapacityConfig.Builder getCapacityConfigBuilder()
       Required. Capacity configuration for the Kafka Connect cluster.
      .google.cloud.managedkafka.v1.CapacityConfig capacity_config = 6 [(.google.api.field_behavior) = REQUIRED];

    • getCapacityConfigOrBuilder

      public CapacityConfigOrBuilder getCapacityConfigOrBuilder()
       Required. Capacity configuration for the Kafka Connect cluster.
      .google.cloud.managedkafka.v1.CapacityConfig capacity_config = 6 [(.google.api.field_behavior) = REQUIRED];
      Specified by:
      getCapacityConfigOrBuilder in interface ConnectClusterOrBuilder

    • getStateValue

      public int getStateValue()
       Output only. The current state of the cluster.
      .google.cloud.managedkafka.v1.ConnectCluster.State state = 8 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getStateValue in interface ConnectClusterOrBuilder
      Returns:
      The enum numeric value on the wire for state.

    • setStateValue

      public ConnectCluster.Builder setStateValue(int value)
       Output only. The current state of the cluster.
      .google.cloud.managedkafka.v1.ConnectCluster.State state = 8 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Parameters:
      value - The enum numeric value on the wire for state to set.
      Returns:
      This builder for chaining.

    • getState

      public ConnectCluster.State getState()
       Output only. The current state of the cluster.
      .google.cloud.managedkafka.v1.ConnectCluster.State state = 8 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Specified by:
      getState in interface ConnectClusterOrBuilder
      Returns:
      The state.

    • setState

      public ConnectCluster.Builder setState(ConnectCluster.State value)
       Output only. The current state of the cluster.
      .google.cloud.managedkafka.v1.ConnectCluster.State state = 8 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Parameters:
      value - The state to set.
      Returns:
      This builder for chaining.

    • clearState

      public ConnectCluster.Builder clearState()
       Output only. The current state of the cluster.
      .google.cloud.managedkafka.v1.ConnectCluster.State state = 8 [(.google.api.field_behavior) = OUTPUT_ONLY];
      Returns:
      This builder for chaining.

    • getConfigCount

      public int getConfigCount()
      Description copied from interface: ConnectClusterOrBuilder
       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`.
      map<string, string> config = 9 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getConfigCount in interface ConnectClusterOrBuilder

    • containsConfig

      public boolean containsConfig(String key)
       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`.
      map<string, string> config = 9 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      containsConfig in interface ConnectClusterOrBuilder

    • getConfig

      @Deprecated public Map<String,String> getConfig()
      Deprecated.
      Use getConfigMap() instead.
      Specified by:
      getConfig in interface ConnectClusterOrBuilder

    • getConfigMap

      public Map<String,String> getConfigMap()
       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`.
      map<string, string> config = 9 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getConfigMap in interface ConnectClusterOrBuilder

    • getConfigOrDefault

      public String getConfigOrDefault(String key, String defaultValue)
       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`.
      map<string, string> config = 9 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getConfigOrDefault in interface ConnectClusterOrBuilder

    • getConfigOrThrow

      public String getConfigOrThrow(String key)
       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`.
      map<string, string> config = 9 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getConfigOrThrow in interface ConnectClusterOrBuilder

    • clearConfig

      public ConnectCluster.Builder clearConfig()

    • removeConfig

      public ConnectCluster.Builder removeConfig(String key)
       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`.
      map<string, string> config = 9 [(.google.api.field_behavior) = OPTIONAL];

    • getMutableConfig

      @Deprecated public Map<String,String> getMutableConfig()
      Deprecated.
      Use alternate mutation accessors instead.

    • putConfig

      public ConnectCluster.Builder putConfig(String key, String value)
       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`.
      map<string, string> config = 9 [(.google.api.field_behavior) = OPTIONAL];

    • putAllConfig

      public ConnectCluster.Builder putAllConfig(Map<String,String> values)
       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`.
      map<string, string> config = 9 [(.google.api.field_behavior) = OPTIONAL];