15.4. 노드 포트를 사용하여 Kafka에 액세스

프로세스

1. nodeport 유형으로 설정된 외부 리스너를 사용하여 Kafka 리소스를 구성합니다.

   예를 들면 다음과 같습니다.

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     labels:
       app: my-cluster
     name: my-cluster
     annotations:
       strimzi.io/node-pools: enabled
       strimzi.io/kraft: enabled
     namespace: myproject
   spec:
     kafka:
       # ...
       listeners:
         - name: external4
           port: 9094
           type: nodeport
           tls: true
           authentication:
             type: tls
           # ...
       # ...

2. 리소스를 생성하거나 업데이트합니다.

   oc apply -f <kafka_configuration_file>

   kafka 브로커의 ID를 확인하기 위한 클러스터 CA 인증서가 시크릿 my-cluster-cluster-ca-cert 에 생성됩니다.

   NodePort 유형 서비스는 각 Kafka 브로커 및 외부 부트스트랩 서비스에 대해 생성됩니다.

   부트스트랩 및 브로커용으로 생성된 노드 포트 서비스

   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

   클라이언트 연결에 사용되는 부트스트랩 주소는 Kafka 리소스의 상태로 전파됩니다.

   부트스트랩 주소의 상태 예

   status:
     clusterId: Y_RJQDGKRXmNF7fEcWldJQ
     conditions:
       - lastTransitionTime: '2023-01-31T14:59:37.113630Z'
         status: 'True'
         type: Ready
     kafkaVersion: 4.0.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: 3.0
    # ...

3. Kafka 리소스의 상태에서 Kafka 클러스터에 액세스하는 데 사용할 수 있는 부트스트랩 주소를 검색합니다.

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

4. 클러스터 CA 인증서를 추출합니다.

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

5. 브로커에 연결하도록 클라이언트를 구성합니다.

   1. Kafka 클라이언트에 연결할 부트스트랩 주소로 부트스트랩 호스트 및 포트를 지정합니다. 예를 들어 ip-10-0-224-199.us-west-2.compute.internal:32650 입니다.

   2. 추출된 인증서를 Kafka 클라이언트의 신뢰 저장소에 추가하여 TLS 연결을 구성합니다.

      클라이언트 인증 메커니즘을 활성화한 경우 클라이언트에서도 구성해야 합니다.