第 4 章 访问 OpenShift 集群外的 Kafka

流程

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

   例如：

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

   Copy to Clipboard Toggle word wrap

2. 创建或更新资源。

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap

   为每个 Kafka 代理创建 NodePort 类型服务，以及外部的 bootstrap service。bootstrap 服务将外部流量路由到 Kafka 代理。用于连接的节点地址会被传播到 Kafka 自定义资源 的状态。

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