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

Interface KafkaBrokerOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
KafkaBroker, KafkaBroker.Builder
public interface KafkaBrokerOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Details

    • getStatPrefix

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

    • getStatPrefixBytes

      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) = { ... }
      Returns:
      The bytes for statPrefix.

    • getForceResponseRewrite

      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;
      Returns:
      The forceResponseRewrite.

    • hasIdBasedBrokerAddressRewriteSpec

      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;
      Returns:
      Whether the idBasedBrokerAddressRewriteSpec field is set.

    • getIdBasedBrokerAddressRewriteSpec

      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;
      Returns:
      The idBasedBrokerAddressRewriteSpec.

    • getIdBasedBrokerAddressRewriteSpecOrBuilder

      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;

    • getApiKeysAllowedList

      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) = { ... }
      Returns:
      A list containing the apiKeysAllowed.

    • getApiKeysAllowedCount

      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) = { ... }
      Returns:
      The count of apiKeysAllowed.

    • getApiKeysAllowed

      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) = { ... }
      Parameters:
      index - The index of the element to return.
      Returns:
      The apiKeysAllowed at the given index.

    • getApiKeysDeniedList

      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) = { ... }
      Returns:
      A list containing the apiKeysDenied.

    • getApiKeysDeniedCount

      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) = { ... }
      Returns:
      The count of apiKeysDenied.

    • getApiKeysDenied

      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) = { ... }
      Parameters:
      index - The index of the element to return.
      Returns:
      The apiKeysDenied at the given index.

    • getBrokerAddressRewriteSpecCase

      KafkaBroker.BrokerAddressRewriteSpecCase getBrokerAddressRewriteSpecCase()