5.2. 使用负载均衡器访问 Kafka

流程

1. 配置一个 Kafka 资源，并将外部监听程序设置为 loadbalancer 类型。

   例如：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     kafka:
       # ...
       listeners:
         - name: external
           port: 9094
           type: loadbalancer
           tls: true
           # ...
       # ...
     zookeeper:
       # ...

   Copy to Clipboard Toggle word wrap

2. 创建或更新资源。

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap

   为每个 Kafka 代理创建 loadbalancer 类型服务和负载均衡器，以及外部 bootstrap 服务。bootstrap 服务将外部流量路由到所有 Kafka 代理。用于连接的 DNS 名称和 IP 地址会传播到每个 服务的状态。

   在 secret <cluster _name> -cluster-ca-cert 中也创建了用于验证 kafka 代理身份的集群 CA 证书。

3. 检索可用于从 Kafka 资源状态访问 Kafka 集群的 bootstrap 服务地址。

   oc get kafka <kafka_cluster_name> -o=jsonpath='{.status.listeners[?(@.name=="<listener_name>")].bootstrapServers}{"\n"}'

   Copy to Clipboard Toggle word wrap

   例如：

   oc get kafka my-cluster -o=jsonpath='{.status.listeners[?(@.name=="external")].bootstrapServers}{"\n"}'

   Copy to Clipboard Toggle word wrap

4. 如果启用了 TLS 加密，提取代理证书颁发机构的公共证书。

   oc get secret KAFKA-CLUSTER-NAME-cluster-ca-cert -o jsonpath='{.data.ca\.crt}' | base64 -d > ca.crt

   Copy to Clipboard Toggle word wrap

   使用 Kafka 客户端中提取的证书配置 TLS 连接。如果您启用了任何身份验证，您还需要在客户端中配置它。