4.6. Apache Kafka에 대한 Knative 브로커 구현

절차

1. Kafka 기반 브로커를 YAML 파일로 생성합니다.

   apiVersion: eventing.knative.dev/v1
   kind: Broker
   metadata:
     annotations:
       eventing.knative.dev/broker.class: Kafka 1
     name: example-kafka-broker
   spec:
     config:
       apiVersion: v1
       kind: ConfigMap
       name: kafka-broker-config 2
       namespace: knative-eventing

   1

   브로커 클래스입니다. 지정하지 않으면 브로커는 클러스터 관리자가 구성한 기본 클래스를 사용합니다. Kafka 브로커를 사용하려면 이 값은 Kafka 여야 합니다.

   2

   Apache Kafka용 Knative 브로커의 기본 구성 맵입니다. 이 구성 맵은 클러스터 관리자가 클러스터에서 Kafka 브로커 기능을 활성화하면 생성됩니다.

2. Kafka 기반 브로커 YAML 파일을 적용합니다.

   $ oc apply -f <filename>

절차

1. Kafka 기반 브로커를 YAML 파일로 생성합니다.

   apiVersion: eventing.knative.dev/v1
   kind: Broker
   metadata:
     annotations:
       eventing.knative.dev/broker.class: Kafka 1
       kafka.eventing.knative.dev/external.topic: <topic_name> 2
   ...

   1

   브로커 클래스입니다. 지정하지 않으면 브로커는 클러스터 관리자가 구성한 기본 클래스를 사용합니다. Kafka 브로커를 사용하려면 이 값은 Kafka 여야 합니다.

   2

   사용하려는 Kafka 항목의 이름입니다.

2. Kafka 기반 브로커 YAML 파일을 적용합니다.

   $ oc apply -f <filename>

절차

1. YAML 파일을 사용하여 Apache Kafka 기반 브로커를 생성합니다.

   apiVersion: eventing.knative.dev/v1
   kind: Broker
   metadata:
     annotations:
       eventing.knative.dev/broker.class: KafkaNamespaced 1
     name: default
     namespace: my-namespace 2
   spec:
     config:
       apiVersion: v1
       kind: ConfigMap
       name: my-config 3
   ...

   1

   격리된 데이터 플레인과 함께 Apache Kafka 브로커를 사용하려면 broker 클래스 값이 KafkaNamespaced 여야 합니다.

   2 3

   참조된 ConfigMap 오브젝트 my-config 는 Broker 오브젝트와 동일한 네임스페이스에 있어야 합니다. 이 경우 my-namespace.

2. Apache Kafka 기반 브로커 YAML 파일을 적용합니다.

   $ oc apply -f <filename>

절차

1. knative-eventing 네임스페이스에서 인증서 파일을 시크릿으로 생성합니다.

   $ oc create secret -n knative-eventing generic <secret_name> \
     --from-literal=protocol=SSL \
     --from-file=ca.crt=caroot.pem \
     --from-file=user.crt=certificate.pem \
     --from-file=user.key=key.pem

   중요

   키 이름 ca.crt,user.crt, user.key를 사용합니다. 이 값은 변경하지 마십시오.

2. KnativeKafka CR을 편집하고 broker 사양에서 보안에 대한 참조를 추가합니다.

   apiVersion: operator.serverless.openshift.io/v1alpha1
   kind: KnativeKafka
   metadata:
     namespace: knative-eventing
     name: knative-kafka
   spec:
     broker:
       enabled: true
       defaultConfig:
         authSecretName: <secret_name>
   ...

절차

1. knative-eventing 네임스페이스에서 인증서 파일을 시크릿으로 생성합니다.

   $ oc create secret -n knative-eventing generic <secret_name> \
     --from-literal=protocol=SASL_SSL \
     --from-literal=sasl.mechanism=<sasl_mechanism> \
     --from-file=ca.crt=caroot.pem \
     --from-literal=password="SecretPassword" \
     --from-literal=user="my-sasl-user"

   • 키 이름 ca.crt,password, sasl.mechanism 을 사용합니다. 이 값은 변경하지 마십시오.

   • 공용 CA 인증서와 함께 SASL을 사용하려면 시크릿을 생성할 때 ca.crt 인수 대신 tls.enabled=true 플래그를 사용해야 합니다. 예를 들면 다음과 같습니다.

     $ oc create secret -n <namespace> generic <kafka_auth_secret> \
       --from-literal=tls.enabled=true \
       --from-literal=password="SecretPassword" \
       --from-literal=saslType="SCRAM-SHA-512" \
       --from-literal=user="my-sasl-user"

2. KnativeKafka CR을 편집하고 broker 사양에서 보안에 대한 참조를 추가합니다.

   apiVersion: operator.serverless.openshift.io/v1alpha1
   kind: KnativeKafka
   metadata:
     namespace: knative-eventing
     name: knative-kafka
   spec:
     broker:
       enabled: true
       defaultConfig:
         authSecretName: <secret_name>
   ...