Kafka 代理（proto）

此扩展的限定名称为 envoy.filters.network.kafka_broker

注意

此扩展仅在 contrib 映像中可用。

注意

此扩展正在开发中。功能尚不完整，不建议用于生产环境。

此扩展尚未经过强化，仅应在上下游都受信任的部署中使用。

提示

此扩展扩展并可与以下扩展类别一起使用

envoy.filters.network

Kafka 代理配置概述.

extensions.filters.network.kafka_broker.v3.KafkaBroker

[extensions.filters.network.kafka_broker.v3.KafkaBroker proto]

{
  "stat_prefix": ...,
  "force_response_rewrite": ...,
  "id_based_broker_address_rewrite_spec": {...}
}

stat_prefix: (string, REQUIRED) 发射统计信息时要使用的前缀。

force_response_rewrite: (bool) 如果代理过滤器应尝试序列化从上游代理接收到的响应，而不是按原样传递接收到的字节，则设置为 true。默认情况下禁用。

id_based_broker_address_rewrite_spec

(extensions.filters.network.kafka_broker.v3.IdBasedBrokerRewriteSpec) 按代理 ID 匹配的代理地址重写规则。

可选的代理地址重写规范。允许代理过滤器重写 Kafka 响应，以便 Kafka 客户端建立的所有连接都指向 Envoy。这允许 Kafka 集群不配置其‘advertised.listeners’ 属性（因为此过滤器将完成必要的重新指向）。这组规则应涵盖正在代理的集群中的所有代理，否则某些节点的地址可能会泄漏到下游客户端。

extensions.filters.network.kafka_broker.v3.IdBasedBrokerRewriteSpec

[extensions.filters.network.kafka_broker.v3.IdBasedBrokerRewriteSpec proto]

按代理 ID 匹配的规则集合。

{
  "rules": []
}

rules: (repeated extensions.filters.network.kafka_broker.v3.IdBasedBrokerRewriteRule)

extensions.filters.network.kafka_broker.v3.IdBasedBrokerRewriteRule

[extensions.filters.network.kafka_broker.v3.IdBasedBrokerRewriteRule proto]

定义一个重写代理地址数据的规则。

{
  "id": ...,
  "host": ...,
  "port": ...
}

id: (uint32) 要匹配的代理 ID。

host: (string, REQUIRED) 要使用的主机值（类似于 Kafka 的 advertised.listeners 的主机部分）。该值应指向 Envoy（而不是 Kafka）侦听器，以便所有客户端流量都通过 Envoy。

port: (uint32) 要使用的端口值（类似于 Kafka 的 advertised.listeners 的端口部分）。该值应指向 Envoy（而不是 Kafka）侦听器，以便所有客户端流量都通过 Envoy。