4.3. 使用 ingress 访问 Kafka

流程

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

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

   例如：

   apiVersion: kafka.strimzi.io/v1beta2
   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_configuration_file>

   Copy to Clipboard Toggle word wrap

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

   在 secret <cluster _name> -cluster-ca-cert 中也创建了用于验证 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 身份验证。