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 Dedicated 웹 콘솔을 사용하는 경우 개발자 화면에서 토폴로지 보기로 이동하여 브로커가 존재하는지 확인할 수 있습니다.

   

절차

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 Dedicated 웹 콘솔을 사용하는 경우 개발자 화면에서 토폴로지 보기로 이동하여 브로커가 존재하는지 확인할 수 있습니다.

   

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 Dedicated 웹 콘솔을 사용하는 경우 개발자 화면에서 토폴로지 보기로 이동하여 브로커가 존재하는지 확인할 수 있습니다.

   

절차

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

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

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

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

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

절차

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

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

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

   

절차

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

프로세스

1. kafka-broker-config 구성 맵을 수정하거나 다음 구성이 포함된 고유한 구성 맵을 생성합니다.

   apiVersion: v1
   kind: ConfigMap
   metadata:
     name: <config_map_name> 1
     namespace: <namespace> 2
   data:
     default.topic.partitions: <integer> 3
     default.topic.replication.factor: <integer> 4
     bootstrap.servers: <list_of_servers> 5

   1

   구성 맵 이름입니다.

   2

   구성 맵이 있는 네임스페이스입니다.

   3

   Kafka 브로커의 주제 파티션 수입니다. 이는 브로커로 이벤트를 얼마나 빠르게 전송할 수 있는지 제어합니다. 파티션 수가 많을 경우 더 많은 컴퓨팅 리소스가 필요합니다.

   4

   주제 메시지의 복제 요인입니다. 이는 데이터 손실을 방지합니다. 복제 요소가 증가하려면 더 큰 컴퓨팅 리소스와 더 많은 스토리지가 필요합니다.

   5

   쉼표로 구분된 부트스트랩 서버 목록입니다. OpenShift Dedicated 클러스터 내부 또는 외부에 있을 수 있으며 브로커가 이벤트를 수신하고 이벤트를 보내는 Kafka 클러스터 목록입니다.

   중요

   default.topic.replication.factor 값은 클러스터의 Kafka 브로커 인스턴스 수보다 작거나 같아야 합니다. 예를 들어 Kafka 브로커가 하나만 있는 경우 default.topic.replication.factor 값은 "1" 을 초과해서는 안 됩니다.

   Kafka 브로커 구성 맵의 예

   apiVersion: v1
   kind: ConfigMap
   metadata:
     name: kafka-broker-config
     namespace: knative-eventing
   data:
     default.topic.partitions: "10"
     default.topic.replication.factor: "3"
     bootstrap.servers: "my-cluster-kafka-bootstrap.kafka:9092"

2. 구성 맵을 적용합니다.

   $ oc apply -f <config_map_filename>

3. Kafka Broker 오브젝트에 대한 구성 맵을 지정합니다.

   Broker 오브젝트의 예

   apiVersion: eventing.knative.dev/v1
   kind: Broker
   metadata:
     name: <broker_name> 1
     namespace: <namespace> 2
     annotations:
       eventing.knative.dev/broker.class: Kafka 3
   spec:
     config:
       apiVersion: v1
       kind: ConfigMap
       name: <config_map_name> 4
       namespace: <namespace> 5
   ...

   1

   브로커 이름입니다.

   2

   브로커가 존재하는 네임스페이스입니다.

   3

   브로커 클래스 주석입니다. 이 예제에서 브로커는 클래스 값 Kafka를 사용하는 Kafka 브로커입니다.

   4

   구성 맵 이름입니다.

   5

   구성 맵이 있는 네임스페이스입니다.

4. 브로커를 적용합니다.

   $ oc apply -f <broker_filename>

프로세스

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
   ...

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

   순서 없음

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

   순서

   정렬된 소비자는 파티션의 다음 메시지를 전달하기 전에 CloudEvent 구독자의 성공적인 응답을 기다리는 파티션별 차단 소비자입니다.

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

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

   $ oc apply -f <filename>