3.3. Apache Kafka의 싱크

프로세스

1. KafkaSink 오브젝트 정의를 YAML 파일로 생성합니다.

   Kafka 싱크 YAML

   apiVersion: eventing.knative.dev/v1alpha1
   kind: KafkaSink
   metadata:
     name: <sink-name>
     namespace: <namespace>
   spec:
     topic: <topic-name>
     bootstrapServers:
      - <bootstrap-server>

2. Kafka 싱크를 생성하려면 KafkaSink YAML 파일을 적용합니다.

   $ oc apply -f <filename>

3. 싱크가 사양에 지정되도록 이벤트 소스를 구성합니다.

   API 서버 소스에 연결된 Kafka 싱크의 예

   apiVersion: sources.knative.dev/v1alpha2
   kind: ApiServerSource
   metadata:
     name: <source-name> 1
     namespace: <namespace> 2
   spec:
     serviceAccountName: <service-account-name> 3
     mode: Resource
     resources:
     - apiVersion: v1
       kind: Event
     sink:
       ref:
         apiVersion: eventing.knative.dev/v1alpha1
         kind: KafkaSink
         name: <sink-name> 4

   1

   이벤트 소스의 이름입니다.

   2

   이벤트 소스의 네임스페이스입니다.

   3

   이벤트 소스의 서비스 계정입니다.

   4

   Kafka 싱크 이름입니다.

프로세스

1. 개발자 화면에서 +추가 보기로 이동합니다.
2. Eventing 카탈로그 에서 이벤트 싱크 를 클릭합니다.
3. 카탈로그 항목에서 KafkaSink 를 검색하고 클릭합니다.
4. 이벤트 싱크 생성을 클릭합니다.

5. 양식 뷰에서 호스트 이름과 포트의 조합인 부트스트랩 서버의 URL을 입력합니다.

   
6. 이벤트 데이터를 보낼 주제의 이름을 입력합니다.
7. 이벤트 싱크의 이름을 입력합니다.
8. 생성을 클릭합니다.

검증

1. 개발자 화면에서 토폴로지 보기로 이동합니다.
2. 생성된 이벤트 싱크를 클릭하여 오른쪽 패널에서 세부 정보를 확인합니다.

프로세스

1. KafkaSink 오브젝트와 동일한 네임스페이스에서 인증서 파일을 시크릿으로 생성합니다.

   중요

   인증서와 키는 PEM 형식이어야 합니다.

   • 암호화 없이 SASL을 사용한 인증의 경우:

     $ oc create secret -n <namespace> generic <secret_name> \
       --from-literal=protocol=SASL_PLAINTEXT \
       --from-literal=sasl.mechanism=<sasl_mechanism> \
       --from-literal=user=<username> \
       --from-literal=password=<password>

   • TLS를 사용한 SASL 및 암호화를 사용한 인증의 경우:

     $ oc create secret -n <namespace> generic <secret_name> \
       --from-literal=protocol=SASL_SSL \
       --from-literal=sasl.mechanism=<sasl_mechanism> \
       --from-file=ca.crt=<my_caroot.pem_file_path> \ 1
       --from-literal=user=<username> \
       --from-literal=password=<password>

     1

     퍼블릭 클라우드 관리 Kafka 서비스를 사용하는 경우 시스템의 루트 CA 세트를 사용하도록 ca.crt 를 생략할 수 있습니다.

   • TLS를 사용한 인증 및 암호화의 경우:

     $ oc create secret -n <namespace> generic <secret_name> \
       --from-literal=protocol=SSL \
       --from-file=ca.crt=<my_caroot.pem_file_path> \ 1
       --from-file=user.crt=<my_cert.pem_file_path> \
       --from-file=user.key=<my_key.pem_file_path>

     1

     퍼블릭 클라우드 관리 Kafka 서비스를 사용하는 경우 시스템의 루트 CA 세트를 사용하도록 ca.crt 를 생략할 수 있습니다.

2. KafkaSink 오브젝트를 생성하거나 수정하고 auth 사양에서 보안에 대한 참조를 추가합니다.

   apiVersion: eventing.knative.dev/v1alpha1
   kind: KafkaSink
   metadata:
      name: <sink_name>
      namespace: <namespace>
   spec:
   ...
      auth:
        secret:
          ref:
            name: <secret_name>
   ...

3. KafkaSink 오브젝트를 적용합니다.

   $ oc apply -f <filename>