3.3. 使用 ingress 访问 Kafka

步骤

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

   指定 bootstrap 服务和 Kafka 代理的 Ingress 主机。

   例如：

   apiVersion: kafka.strimzi.io/v1beta1
   kind: Kafka
   spec:
     kafka:
       # ...
       listeners:
         - name: external
           port: 9094
           type: ingress
           tls: true
           authentication:
             type: tls
           configuration: 

   1

   
             bootstrap:
               host: bootstrap.myingress.com
             brokers:
             - broker: 0
               host: broker-0.myingress.com
             - broker: 1
               host: broker-1.myingress.com
             - broker: 2
               host: broker-2.myingress.com
       # ...
     zookeeper:
       # ...

   Copy to Clipboard Toggle word wrap

   1

   bootstrap 服务和 Kafka 代理的 Ingress 主机。

2. 创建或更新资源。

   oc apply -f KAFKA-CONFIG-FILE

   Copy to Clipboard Toggle word wrap

   为每个 Kafka 代理创建 ClusterIP 类型服务，以及一个额外的 bootstrap 服务。这些服务供 Ingress 控制器用于将流量路由到 Kafka 代理。还会为每个服务创建一个 Ingress 资源，以使用 Ingress 控制器公开它们。Ingress 主机传播到每个 服务的状态。

   也使用与 Kafka 资源相同的名称来创建用于验证 kafka 代理身份的集群 CA 证书。

   使用 Kafka 客户端中的 配置 和端口 443(BOOTSTRAP-HOST:443)中指定的 bootstrap 主机 地址，作为 bootstrap 地址 连接到 Kafka 集群。

3. 提取代理认证机构的公共证书。

   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 连接。如果启用了任何身份验证，您还需要配置 SASL 或 TLS 身份验证。