13.5. 使用节点端口访问 Kafka

流程

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

   例如：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     labels:
       app: my-cluster
     name: my-cluster
     namespace: myproject
   spec:
     kafka:
       # ...
       listeners:
         - name: external4
           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

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

   为每个 Kafka 代理以及外部 bootstrap 服务创建 NodePort 类型服务。

   为 bootstrap 和代理创建的节点端口服务

   NAME                                  TYPE      CLUSTER-IP      PORT(S)
   my-cluster-kafka-external4-0          NodePort  172.30.55.13    9094:31789/TCP
   my-cluster-kafka-external4-1          NodePort  172.30.250.248  9094:30028/TCP
   my-cluster-kafka-external4-2          NodePort  172.30.115.81   9094:32650/TCP
   my-cluster-kafka-external4-bootstrap  NodePort  172.30.30.23    9094:32650/TCP

   Copy to Clipboard Toggle word wrap

   用于客户端连接的 bootstrap 地址传播到 Kafka 资源的 status。

   bootstrap 地址的状态示例

   status:
     clusterId: Y_RJQDGKRXmNF7fEcWldJQ
     conditions:
       - lastTransitionTime: '2023-01-31T14:59:37.113630Z'
         status: 'True'
         type: Ready
     kafkaVersion: 3.6.0
     listeners:
       # ...
       - addresses:
           - host: ip-10-0-224-199.us-west-2.compute.internal
             port: 32650
         bootstrapServers: 'ip-10-0-224-199.us-west-2.compute.internal:32650'
         certificates:
           - |
             -----BEGIN CERTIFICATE-----
   
             -----END CERTIFICATE-----
         name: external4
     observedGeneration: 2
     operatorLastSuccessfulVersion: 2.6
    # ...

   Copy to Clipboard Toggle word wrap

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

   oc get kafka my-cluster -o=jsonpath='{.status.listeners[?(@.name=="external4")].bootstrapServers}{"\n"}'
   
   ip-10-0-224-199.us-west-2.compute.internal:32650

   Copy to Clipboard Toggle word wrap

4. 提取集群 CA 证书。

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

   Copy to Clipboard Toggle word wrap

5. 将您的客户端配置为连接到代理。

   1. 指定 Kafka 客户端中的 bootstrap 主机和端口作为连接到 Kafka 集群的 bootstrap 地址。例如，ip-10-0-224-199.us-west-2.compute.internal:32650。

   2. 将提取的证书添加到 Kafka 客户端的信任存储中，以配置 TLS 连接。

      如果启用了客户端身份验证机制，您还需要在客户端中配置它。