第 7 章 使用带有 3scale 的 Kafka 网桥

标头修改策略允许修改现有的 HTTP 标头，或向通过网关的请求或响应添加新的标头。对于 3scale 集成，策略会为从 HTTP 客户端传递到 Kafka 网桥的每个请求添加标头。

当 Kafka Bridge 收到创建新消费者的请求时，它会返回包含 base_uri 字段的 JSON 有效负载，其中包含使用者必须用于所有后续请求的 URI。例如：

{
  "instance_id": "consumer-1",
  "base_uri":"http://my-bridge:8080/consumers/my-group/instances/consumer1"
}

使用 APIcast 时，客户端会将所有后续请求发送到网关，而不是直接发送到 Kafka 网桥。因此 URI 需要网关主机名，而不是网关后面的 Kafka 网桥地址。

使用标头修改策略，标头添加到来自 HTTP 客户端的请求中，以便 Kafka Bridge 使用网关主机名。

例如，通过应用 Forwarded: host=my-gateway:80;proto=http 标头，Kafka 网桥向使用者提供以下内容：

{
    "instance_id": "consumer-1",
    "base_uri":"http://my-gateway:80/consumers/my-group/instances/consumer1"
}

X-Forwarded-Path 标头承载从客户端到网关的请求中包含的原始路径。此标头与网关支持多个 Kafka Bridge 实例时应用的路由策略严格相关。

当有多个 Kafka Bridge 实例时，会应用路由策略。请求必须发送到最初创建使用者的同一 Kafka Bridge 实例，因此请求必须指定网关将请求转发到适当的 Kafka Bridge 实例的路由。

每个网桥实例都有一个路由策略名称，路由则使用 名称来执行。部署 Kafka Bridge 时，您可以在 KafkaBridge 自定义资源中指定名称。

例如，从使用者到以下每个请求（使用 X-Forwarded-Path）

http://my-gateway:80/my-bridge-1/consumers/my-group/instances/consumer1

转发到：

http://my-bridge-1-bridge-service:8080/consumers/my-group/instances/consumer1

URL 重写策略会删除网桥名称，因为它在将请求从网关转发到 Kafka Bridge 时不会用到。

URL 重新连接策略确保从客户端到特定 Kafka Bridge 实例的请求在将网关的请求转发到 Kafka Bridge 时不包含网桥名称。

网桥名称不用于网桥公开的端点。