5.4. 브로커

검증

1. kn 명령을 사용하여 기존 브로커를 모두 나열합니다.

   $ kn broker list

   출력 예

   NAME      URL                                                                     AGE   CONDITIONS   READY   REASON
   default   http://broker-ingress.knative-eventing.svc.cluster.local/test/default   45s   5 OK / 5     True

2. 선택 사항: OpenShift Container Platform 웹 콘솔을 사용하는 경우 개발자 화면에서 토폴로지 보기로 이동하여 브로커가 존재하는지 관찰할 수 있습니다.

   

프로세스

1. eventing.knative.dev/injection: enabled 주석이 있는 Trigger 오브젝트를 YAML 파일로 생성합니다.

   apiVersion: eventing.knative.dev/v1
   kind: Trigger
   metadata:
     annotations:
       eventing.knative.dev/injection: enabled
     name: <trigger_name>
   spec:
     broker: default
     subscriber: 1
       ref:
         apiVersion: serving.knative.dev/v1
         kind: Service
         name: <service_name>

   1

   트리거에서 이벤트를 전송할 대상 이벤트 싱크 또는 구독자에 대한 세부 정보를 지정합니다.

2. Trigger YAML 파일을 적용합니다.

   $ oc apply -f <filename>

1. oc 명령을 사용하여 브로커를 가져옵니다.

   $ oc -n <namespace> get broker default

   출력 예

   NAME      READY     REASON    URL                                                                     AGE
   default   True                http://broker-ingress.knative-eventing.svc.cluster.local/test/default   3m56s

2. 선택 사항: OpenShift Container Platform 웹 콘솔을 사용하는 경우 개발자 화면에서 토폴로지 보기로 이동하여 브로커가 존재하는지 관찰할 수 있습니다.

   

1. oc 명령을 사용하여 브로커를 가져옵니다.

   $ oc -n <namespace> get broker <broker_name>

   명령 예

   $ oc -n default get broker default

   출력 예

   NAME      READY     REASON    URL                                                                     AGE
   default   True                http://broker-ingress.knative-eventing.svc.cluster.local/test/default   3m56s

2. 선택 사항: OpenShift Container Platform 웹 콘솔을 사용하는 경우 개발자 화면에서 토폴로지 보기로 이동하여 브로커가 존재하는지 관찰할 수 있습니다.

   

절차

1. 네임스페이스에서 eventing.knative.dev/injection=enabled 라벨을 제거합니다.

   $ oc label namespace <namespace> eventing.knative.dev/injection-

   주석을 제거하면 Knative에서 브로커를 삭제한 후 다시 생성하지 않습니다.

2. 선택한 네임스페이스에서 브로커를 삭제합니다.

   $ oc -n <namespace> delete broker <broker_name>

절차

1. 개발자 화면에서 +추가 → 브로커 로 이동합니다. Broker 페이지가 표시됩니다.
2. 선택 사항: 브로커 의 이름을 업데이트합니다. 이름을 업데이트하지 않으면 생성된 브로커의 이름이 default 입니다.
3. 생성을 클릭합니다.

1. 개발자 화면에서 토폴로지로 이동합니다.

2. mt-broker-ingress,mt-broker-filter, mt-broker-controller 구성 요소를 확인합니다.

   

절차

1. OpenShift Container Platform 웹 콘솔의 관리자 화면에서 Serverless → Eventing으로 이동합니다.
2. 생성 목록에서 브로커를 선택합니다. 그러면 브로커 생성 페이지로 이동합니다.
3. 선택 사항: 브로커의 YAML 구성을 수정합니다.
4. 생성을 클릭합니다.

절차

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

   Knative Kafka 브로커의 기본 구성 맵입니다. 이 구성 맵은 클러스터 관리자가 클러스터에서 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. 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을 편집하고 브로커 사양의 보안에 참조를 추가합니다.

   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,암호, 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을 편집하고 브로커 사양의 보안에 참조를 추가합니다.

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

절차

1. Trigger 오브젝트를 생성하거나 수정하고 kafka.eventing.knative.dev/delivery.order 주석을 설정합니다.

   apiVersion: eventing.knative.dev/v1
   kind: Trigger
   metadata:
     name: <trigger_name>
     annotations:
        kafka.eventing.knative.dev/delivery.order: ordered
   ...

   지원되는 소비자 제공 보장은 다음과 같습니다.

   순서가 지정되지 않음

   순서가 지정되지 않은 소비자는 적절한 오프셋 관리를 유지하면서 순서가 지정되지 않은 메시지를 전달하는 비차단 소비자입니다.

   ordered

   순서가 지정된 소비자는 CloudEvent 구독자의 성공적인 응답을 기다린 후 파티션의 다음 메시지를 전달하기 전에 대기 중인 소비자별 소비자입니다.

   기본 주문 보장은 순서가 지정되지 않습니다.

2. Trigger 오브젝트를 적용합니다.

   $ oc apply -f <filename>