Package io.envoyproxy.envoy.config.filter.network.kafka_broker.v2alpha1

Class KafkaBroker.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder>
io.envoyproxy.envoy.config.filter.network.kafka_broker.v2alpha1.KafkaBroker.Builder
All Implemented Interfaces:
com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, KafkaBrokerOrBuilder, Cloneable
Enclosing class:
KafkaBroker
public static final class KafkaBroker.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder> implements KafkaBrokerOrBuilder
 [#protodoc-title: Kafka Broker]
 Kafka Broker :ref:`configuration overview <config_network_filters_kafka_broker>`.
 [#extension: envoy.filters.network.kafka_broker]
 [#next-free-field: 6]
Protobuf type envoy.config.filter.network.kafka_broker.v2alpha1.KafkaBroker

  • Method Details

    • getDescriptor

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

    • internalGetFieldAccessorTable

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

    • clear

      public KafkaBroker.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.GeneratedMessageV3.Builder<KafkaBroker.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.GeneratedMessageV3.Builder<KafkaBroker.Builder>

    • getDefaultInstanceForType

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

    • build

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

    • buildPartial

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

    • clone

      public KafkaBroker.Builder clone()
      Specified by:
      clone in interface com.google.protobuf.Message.Builder
      Specified by:
      clone in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clone in class com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder>

    • setField

      public KafkaBroker.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
      Specified by:
      setField in interface com.google.protobuf.Message.Builder
      Overrides:
      setField in class com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder>

    • clearField

      public KafkaBroker.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
      Specified by:
      clearField in interface com.google.protobuf.Message.Builder
      Overrides:
      clearField in class com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder>

    • clearOneof

      public KafkaBroker.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
      Specified by:
      clearOneof in interface com.google.protobuf.Message.Builder
      Overrides:
      clearOneof in class com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder>

    • setRepeatedField

      public KafkaBroker.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
      Specified by:
      setRepeatedField in interface com.google.protobuf.Message.Builder
      Overrides:
      setRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder>

    • addRepeatedField

      public KafkaBroker.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
      Specified by:
      addRepeatedField in interface com.google.protobuf.Message.Builder
      Overrides:
      addRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder>

    • mergeFrom

      public KafkaBroker.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<KafkaBroker.Builder>

    • mergeFrom

      public KafkaBroker.Builder mergeFrom(KafkaBroker other)

    • isInitialized

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

    • mergeFrom

      public KafkaBroker.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<KafkaBroker.Builder>
      Throws:
      IOException

    • getBrokerAddressRewriteSpecCase

      public KafkaBroker.BrokerAddressRewriteSpecCase getBrokerAddressRewriteSpecCase()
      Specified by:
      getBrokerAddressRewriteSpecCase in interface KafkaBrokerOrBuilder

    • clearBrokerAddressRewriteSpec

      public KafkaBroker.Builder clearBrokerAddressRewriteSpec()

    • getStatPrefix

      public String getStatPrefix()
       The prefix to use when emitting :ref:`statistics <config_network_filters_kafka_broker_stats>`.
      string stat_prefix = 1 [(.validate.rules) = { ... }
      Specified by:
      getStatPrefix in interface KafkaBrokerOrBuilder
      Returns:
      The statPrefix.

    • getStatPrefixBytes

      public com.google.protobuf.ByteString getStatPrefixBytes()
       The prefix to use when emitting :ref:`statistics <config_network_filters_kafka_broker_stats>`.
      string stat_prefix = 1 [(.validate.rules) = { ... }
      Specified by:
      getStatPrefixBytes in interface KafkaBrokerOrBuilder
      Returns:
      The bytes for statPrefix.

    • setStatPrefix

      public KafkaBroker.Builder setStatPrefix(String value)
       The prefix to use when emitting :ref:`statistics <config_network_filters_kafka_broker_stats>`.
      string stat_prefix = 1 [(.validate.rules) = { ... }
      Parameters:
      value - The statPrefix to set.
      Returns:
      This builder for chaining.

    • clearStatPrefix

      public KafkaBroker.Builder clearStatPrefix()
       The prefix to use when emitting :ref:`statistics <config_network_filters_kafka_broker_stats>`.
      string stat_prefix = 1 [(.validate.rules) = { ... }
      Returns:
      This builder for chaining.

    • setStatPrefixBytes

      public KafkaBroker.Builder setStatPrefixBytes(com.google.protobuf.ByteString value)
       The prefix to use when emitting :ref:`statistics <config_network_filters_kafka_broker_stats>`.
      string stat_prefix = 1 [(.validate.rules) = { ... }
      Parameters:
      value - The bytes for statPrefix to set.
      Returns:
      This builder for chaining.

    • getForceResponseRewrite

      public boolean getForceResponseRewrite()
       Set to true if broker filter should attempt to serialize the received responses from the
 upstream broker instead of passing received bytes as is.
 Disabled by default.
      bool force_response_rewrite = 2;
      Specified by:
      getForceResponseRewrite in interface KafkaBrokerOrBuilder
      Returns:
      The forceResponseRewrite.

    • setForceResponseRewrite

      public KafkaBroker.Builder setForceResponseRewrite(boolean value)
       Set to true if broker filter should attempt to serialize the received responses from the
 upstream broker instead of passing received bytes as is.
 Disabled by default.
      bool force_response_rewrite = 2;
      Parameters:
      value - The forceResponseRewrite to set.
      Returns:
      This builder for chaining.

    • clearForceResponseRewrite

      public KafkaBroker.Builder clearForceResponseRewrite()
       Set to true if broker filter should attempt to serialize the received responses from the
 upstream broker instead of passing received bytes as is.
 Disabled by default.
      bool force_response_rewrite = 2;
      Returns:
      This builder for chaining.

    • hasIdBasedBrokerAddressRewriteSpec

      public boolean hasIdBasedBrokerAddressRewriteSpec()
       Broker address rewrite rules that match by broker ID.
      .envoy.config.filter.network.kafka_broker.v2alpha1.IdBasedBrokerRewriteSpec id_based_broker_address_rewrite_spec = 3;
      Specified by:
      hasIdBasedBrokerAddressRewriteSpec in interface KafkaBrokerOrBuilder
      Returns:
      Whether the idBasedBrokerAddressRewriteSpec field is set.

    • getIdBasedBrokerAddressRewriteSpec

      public IdBasedBrokerRewriteSpec getIdBasedBrokerAddressRewriteSpec()
       Broker address rewrite rules that match by broker ID.
      .envoy.config.filter.network.kafka_broker.v2alpha1.IdBasedBrokerRewriteSpec id_based_broker_address_rewrite_spec = 3;
      Specified by:
      getIdBasedBrokerAddressRewriteSpec in interface KafkaBrokerOrBuilder
      Returns:
      The idBasedBrokerAddressRewriteSpec.

    • setIdBasedBrokerAddressRewriteSpec

      public KafkaBroker.Builder setIdBasedBrokerAddressRewriteSpec(IdBasedBrokerRewriteSpec value)
       Broker address rewrite rules that match by broker ID.
      .envoy.config.filter.network.kafka_broker.v2alpha1.IdBasedBrokerRewriteSpec id_based_broker_address_rewrite_spec = 3;

    • setIdBasedBrokerAddressRewriteSpec

      public KafkaBroker.Builder setIdBasedBrokerAddressRewriteSpec(IdBasedBrokerRewriteSpec.Builder builderForValue)
       Broker address rewrite rules that match by broker ID.
      .envoy.config.filter.network.kafka_broker.v2alpha1.IdBasedBrokerRewriteSpec id_based_broker_address_rewrite_spec = 3;

    • mergeIdBasedBrokerAddressRewriteSpec

      public KafkaBroker.Builder mergeIdBasedBrokerAddressRewriteSpec(IdBasedBrokerRewriteSpec value)
       Broker address rewrite rules that match by broker ID.
      .envoy.config.filter.network.kafka_broker.v2alpha1.IdBasedBrokerRewriteSpec id_based_broker_address_rewrite_spec = 3;

    • clearIdBasedBrokerAddressRewriteSpec

      public KafkaBroker.Builder clearIdBasedBrokerAddressRewriteSpec()
       Broker address rewrite rules that match by broker ID.
      .envoy.config.filter.network.kafka_broker.v2alpha1.IdBasedBrokerRewriteSpec id_based_broker_address_rewrite_spec = 3;

    • getIdBasedBrokerAddressRewriteSpecBuilder

      public IdBasedBrokerRewriteSpec.Builder getIdBasedBrokerAddressRewriteSpecBuilder()
       Broker address rewrite rules that match by broker ID.
      .envoy.config.filter.network.kafka_broker.v2alpha1.IdBasedBrokerRewriteSpec id_based_broker_address_rewrite_spec = 3;

    • getIdBasedBrokerAddressRewriteSpecOrBuilder

      public IdBasedBrokerRewriteSpecOrBuilder getIdBasedBrokerAddressRewriteSpecOrBuilder()
       Broker address rewrite rules that match by broker ID.
      .envoy.config.filter.network.kafka_broker.v2alpha1.IdBasedBrokerRewriteSpec id_based_broker_address_rewrite_spec = 3;
      Specified by:
      getIdBasedBrokerAddressRewriteSpecOrBuilder in interface KafkaBrokerOrBuilder

    • getApiKeysAllowedList

      public List<Integer> getApiKeysAllowedList()
       Optional list of allowed Kafka API keys. Only requests with provided API keys will be
 routed, otherwise the connection will be closed. No effect if empty.
      repeated uint32 api_keys_allowed = 4 [(.validate.rules) = { ... }
      Specified by:
      getApiKeysAllowedList in interface KafkaBrokerOrBuilder
      Returns:
      A list containing the apiKeysAllowed.

    • getApiKeysAllowedCount

      public int getApiKeysAllowedCount()
       Optional list of allowed Kafka API keys. Only requests with provided API keys will be
 routed, otherwise the connection will be closed. No effect if empty.
      repeated uint32 api_keys_allowed = 4 [(.validate.rules) = { ... }
      Specified by:
      getApiKeysAllowedCount in interface KafkaBrokerOrBuilder
      Returns:
      The count of apiKeysAllowed.

    • getApiKeysAllowed

      public int getApiKeysAllowed(int index)
       Optional list of allowed Kafka API keys. Only requests with provided API keys will be
 routed, otherwise the connection will be closed. No effect if empty.
      repeated uint32 api_keys_allowed = 4 [(.validate.rules) = { ... }
      Specified by:
      getApiKeysAllowed in interface KafkaBrokerOrBuilder
      Parameters:
      index - The index of the element to return.
      Returns:
      The apiKeysAllowed at the given index.

    • setApiKeysAllowed

      public KafkaBroker.Builder setApiKeysAllowed(int index, int value)
       Optional list of allowed Kafka API keys. Only requests with provided API keys will be
 routed, otherwise the connection will be closed. No effect if empty.
      repeated uint32 api_keys_allowed = 4 [(.validate.rules) = { ... }
      Parameters:
      index - The index to set the value at.
      value - The apiKeysAllowed to set.
      Returns:
      This builder for chaining.

    • addApiKeysAllowed

      public KafkaBroker.Builder addApiKeysAllowed(int value)
       Optional list of allowed Kafka API keys. Only requests with provided API keys will be
 routed, otherwise the connection will be closed. No effect if empty.
      repeated uint32 api_keys_allowed = 4 [(.validate.rules) = { ... }
      Parameters:
      value - The apiKeysAllowed to add.
      Returns:
      This builder for chaining.

    • addAllApiKeysAllowed

      public KafkaBroker.Builder addAllApiKeysAllowed(Iterable<? extends Integer> values)
       Optional list of allowed Kafka API keys. Only requests with provided API keys will be
 routed, otherwise the connection will be closed. No effect if empty.
      repeated uint32 api_keys_allowed = 4 [(.validate.rules) = { ... }
      Parameters:
      values - The apiKeysAllowed to add.
      Returns:
      This builder for chaining.

    • clearApiKeysAllowed

      public KafkaBroker.Builder clearApiKeysAllowed()
       Optional list of allowed Kafka API keys. Only requests with provided API keys will be
 routed, otherwise the connection will be closed. No effect if empty.
      repeated uint32 api_keys_allowed = 4 [(.validate.rules) = { ... }
      Returns:
      This builder for chaining.

    • getApiKeysDeniedList

      public List<Integer> getApiKeysDeniedList()
       Optional list of denied Kafka API keys. Requests with API keys matching this list will have
 the connection closed. No effect if empty.
      repeated uint32 api_keys_denied = 5 [(.validate.rules) = { ... }
      Specified by:
      getApiKeysDeniedList in interface KafkaBrokerOrBuilder
      Returns:
      A list containing the apiKeysDenied.

    • getApiKeysDeniedCount

      public int getApiKeysDeniedCount()
       Optional list of denied Kafka API keys. Requests with API keys matching this list will have
 the connection closed. No effect if empty.
      repeated uint32 api_keys_denied = 5 [(.validate.rules) = { ... }
      Specified by:
      getApiKeysDeniedCount in interface KafkaBrokerOrBuilder
      Returns:
      The count of apiKeysDenied.

    • getApiKeysDenied

      public int getApiKeysDenied(int index)
       Optional list of denied Kafka API keys. Requests with API keys matching this list will have
 the connection closed. No effect if empty.
      repeated uint32 api_keys_denied = 5 [(.validate.rules) = { ... }
      Specified by:
      getApiKeysDenied in interface KafkaBrokerOrBuilder
      Parameters:
      index - The index of the element to return.
      Returns:
      The apiKeysDenied at the given index.

    • setApiKeysDenied

      public KafkaBroker.Builder setApiKeysDenied(int index, int value)
       Optional list of denied Kafka API keys. Requests with API keys matching this list will have
 the connection closed. No effect if empty.
      repeated uint32 api_keys_denied = 5 [(.validate.rules) = { ... }
      Parameters:
      index - The index to set the value at.
      value - The apiKeysDenied to set.
      Returns:
      This builder for chaining.

    • addApiKeysDenied

      public KafkaBroker.Builder addApiKeysDenied(int value)
       Optional list of denied Kafka API keys. Requests with API keys matching this list will have
 the connection closed. No effect if empty.
      repeated uint32 api_keys_denied = 5 [(.validate.rules) = { ... }
      Parameters:
      value - The apiKeysDenied to add.
      Returns:
      This builder for chaining.

    • addAllApiKeysDenied

      public KafkaBroker.Builder addAllApiKeysDenied(Iterable<? extends Integer> values)
       Optional list of denied Kafka API keys. Requests with API keys matching this list will have
 the connection closed. No effect if empty.
      repeated uint32 api_keys_denied = 5 [(.validate.rules) = { ... }
      Parameters:
      values - The apiKeysDenied to add.
      Returns:
      This builder for chaining.

    • clearApiKeysDenied

      public KafkaBroker.Builder clearApiKeysDenied()
       Optional list of denied Kafka API keys. Requests with API keys matching this list will have
 the connection closed. No effect if empty.
      repeated uint32 api_keys_denied = 5 [(.validate.rules) = { ... }
      Returns:
      This builder for chaining.

    • setUnknownFields

      public final KafkaBroker.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
      Specified by:
      setUnknownFields in interface com.google.protobuf.Message.Builder
      Overrides:
      setUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder>

    • mergeUnknownFields

      public final KafkaBroker.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
      Specified by:
      mergeUnknownFields in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<KafkaBroker.Builder>