5장. OpenShift 클러스터 외부에서 Kafka에 액세스

절차

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

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

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

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

   oc apply -f <kafka_configuration_file>

   각 Kafka 브로커 및 외부 부트스트랩 서비스에 대해 NodePort 유형 서비스가 생성됩니다. 부트스트랩 서비스는 외부 트래픽을 Kafka 브로커로 라우팅합니다. 연결에 사용되는 노드 주소는 Kafka 사용자 정의 리소스의 상태로 전파됩니다.

   kafka 브로커의 ID를 확인하는 클러스터 CA 인증서도 시크릿 < cluster_name> -cluster-ca-cert 에 생성됩니다.

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

   oc get kafka <kafka_cluster_name> -o=jsonpath='{.status.listeners[?(@.name=="<listener_name>")].bootstrapServers}{"\n"}'

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

   oc get kafka my-cluster -o=jsonpath='{.status.listeners[?(@.name=="external")].bootstrapServers}{"\n"}'

4. TLS 암호화가 활성화된 경우 브로커 인증 기관의 공개 인증서를 추출합니다.

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

   Kafka 클라이언트에서 추출된 인증서를 사용하여 TLS 연결을 구성합니다. 인증을 활성화한 경우 클라이언트에서도 구성해야 합니다.