package envoy.config.filter.network.kafka_broker.v2alpha1

Get desktop application:
View/edit binary Protocol Buffers messages

Defines a rule to rewrite broker address data.

Used in: IdBasedBrokerRewriteSpec

• uint32 id = 1

  Broker ID to match.

• string host = 2

  The host value to use (resembling the host part of Kafka's advertised.listeners). The value should point to the Envoy (not Kafka) listener, so that all client traffic goes through Envoy.

• uint32 port = 3

  The port value to use (resembling the port part of Kafka's advertised.listeners). The value should point to the Envoy (not Kafka) listener, so that all client traffic goes through Envoy.

Collection of rules matching by broker ID.

Used in: KafkaBroker

• repeated IdBasedBrokerRewriteRule rules = 1

[#protodoc-title: Kafka Broker] Kafka Broker :ref:`configuration overview <config_network_filters_kafka_broker>`. [#extension: envoy.filters.network.kafka_broker] [#next-free-field: 6]

• string stat_prefix = 1

  The prefix to use when emitting :ref:`statistics <config_network_filters_kafka_broker_stats>`.

• bool force_response_rewrite = 2

  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.

• oneof broker_address_rewrite_spec

  Optional broker address rewrite specification. Allows the broker filter to rewrite Kafka responses so that all connections established by the Kafka clients point to Envoy. This allows Kafka cluster not to configure its 'advertised.listeners' property (as the necessary re-pointing will be done by this filter). This collection of rules should cover all brokers in the cluster that is being proxied, otherwise some nodes' addresses might leak to the downstream clients.

  • IdBasedBrokerRewriteSpec id_based_broker_address_rewrite_spec = 3

    Broker address rewrite rules that match by broker ID.

• repeated uint32 api_keys_allowed = 4

  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_denied = 5

  Optional list of denied Kafka API keys. Requests with API keys matching this list will have the connection closed. No effect if empty.