Kafka 메시지 트리거를 사용하여 플로우 생성

Kafka 스트림에서 이벤트를 처리하는 플로우를 빌드합니다. 지정된 주제에서 이벤트를 사용할 수 있으면 플로우를 시작합니다.

시작하기 전에

필요한 역할: flow_designer 또는 admin

이 트리거를 사용하려면 구독이 스트리밍 연결 필요합니다. 자세한 내용은 https://www.servicenow.com/now-platform/workflow-data-fabric.html 문서를 참조하십시오.

이 트리거에는 스트림 커넥트 설치 관리자 [com.glide.hub.stream_connect.installer] 플러그인이 ServiceNow 필요합니다.

프로시저

1. 다음으로 이동 모두 > 프로세스 자동화 > 플로우 디자이너.
2. Click 신규 > 플로우.
3. 플로우 속성을 정의합니다.
   자세한 내용은 워크플로우 스튜디오에서 플로우 생성 문서를 참조하십시오.
4. 트리거 섹션에서 트리거 추가 를 클릭하고 애플리케이션 > Kafka 메시지.
5. Kafka 메시지 양식의 필드에 내용을 입력합니다.

   필드	설명
   주제 별칭	메시지를 모니터링할 주제의 주제 별칭에 대한 참조입니다. 주제 별칭은 기본 Hermes 또는 직접 Kafka 주제에 연결할 수 있는 고유한 주제 이름입니다.
   직렬화 형식	메시지의 직렬화 형식입니다. 다음 중 하나를 선택하십시오. 일반 텍스트: 일반 텍스트 메시지에 대해 이 옵션을 선택합니다. 이것이 기본 형식입니다. 인코딩됨: Avro 형식의 Apache 메시지에 대해 이 옵션을 선택합니다. 일반 텍스트 메시지를 Avro 형식으로 변환하려면 스키마가 필요합니다. 스키 마 레지스트리 필드에서 스키마 레지스트리를 선택합니다. 스키마에 대한 자세한 내용은 다음 문서를 참조하십시오 Schema management in Stream Connect.
   스키마 레지스트리	선택한 스키마의 레지스트리입니다. 다음 중 하나를 선택하십시오. 독립 실행형 스키마 레지스트리 융합 스키마 레지스트리 이 필드는 직렬화 형식 이 인코딩됨으로 설정된 경우에만 나타납니다. 융합 스키마 레지스트리의 경우 받은 메시지의 스키마 ID가 스키마 테이블에 없는 경우 시스템은 구성된 REST 연결을 사용하여 스키마를 동적으로 임포트합니다.
   고급 옵션
   처리 시작	날짜별로 구성된 큐의 시작 또는 끝에서 메시지 처리를 시작하는 옵션입니다. 다음 중 하나를 선택하십시오. 큐의 가장 오래된 메시지: 큐에서 가장 오래된 메시지부터 처리를 시작합니다. 큐의 끝: 큐의 최신 메시지에서 처리를 시작합니다.
   실행당 처리할 메시지 수	실행당 처리되는 메시지 수를 지정하거나 시스템이 메시지 수를 결정하도록 하는 옵션입니다. 다음 중 하나를 선택하십시오. 자동 최적화: 시스템은 실행당 처리할 메시지 수를 결정합니다. 수동으로 재정의(고급): 실행당 처리할 메시지 수를 지정합니다.
   메시지 수 입력(시스템 작성 값이 낮은 경우 무시됨)	각 실행을 처리할 메시지 수입니다. 이 필드는 실행당 처리할 메시지 수가수동으로 재정의(고급)로 설정된 경우에만 나타납니다. 유형: 정수 기본값: 100 최소값: 1 최대값: 100,000 선택한 숫자가 시스템에서 계산한 숫자보다 크면 플로우는 시스템에서 계산한 숫자로 실행됩니다. 메시지 크기에 따라 실행당 처리되는 메시지 수가 지정된 수보다 낮을 수 있습니다.

6. 완료를 클릭합니다.
7. 옵션: 최대 동시 허용 사용자 수 필드와 상대적 가중치 필드를 설정합니다.
   최대 동시 허용 사용자 수 필드는 만들 파티션 그룹 수와 사용할 병렬 프로세서 수를 결정합니다. 상대적 가중치 필드를 사용하면 다른 소비자에 비해 소비자에게 더 많은 처리 시간을 할당할 수 있습니다.
   1. 다음으로 이동 모두 > 프로세스 자동화 > 플로우 관리 > 설정.
   2. 플로우/하위 플로우/작업 필드에서 플로우에 대한 정보 아이콘()을 선택한 다음 기록 열기를 선택합니다.
   3. 추가 작업 아이콘( )을 선택하고 뷰 > Kafka.
      최대 동시 허용 사용자 수 필드가 양식에 나타납니다.
   4. 상대적 가중치 필드를 보려면 고급을 선택합니다.
   5. 최대 동시 허용 사용자 수 및 상대적 가중치 값을 설정합니다.

      필드	설명
      최대 동시 허용 사용자 수	메시지를 소비하는 데 사용할 최대 병렬 프로세서 수와 만들 파티션 그룹 수입니다. 기본값: 1
      상대적 가중치	각 주기에서 메시지 처리를 위해 다른 소비자에 상대적으로 소비자에게 할당된 최대 시간입니다. 예를 들어, 상대적 가중치가 다른 소비자보다 두 배 높은 소비자는 두 배의 시간을 얻습니다. 상대적 가중치가 동일한 소비자에게는 동일한 시간이 부여됩니다. 최소값은 5입니다. 최대값은 2000입니다. 기본값은 최대 동시 허용 사용자 수에 속성 값을 glide.ih.kafka.consumer.max_seconds_per_partition_group 곱한 값과 같습니다. 이 속성은 glide.ih.kafka.consumer.max_seconds_per_partition_group 각 파티션 그룹에 할당되는 최대 시간(초)을 지정합니다. 기본값은 10입니다. 시스템은 상대적 가중치를 사용하여 구독에 대한 파티션 그룹 시간 제한을 계산합니다. 파티션 그룹 시간 제한은 특정 구독의 각 파티션 그룹에 할당되는 최대 시간(밀리초)을 지정합니다. 이 필드는 고급 을 선택한 경우에만 나타납니다.

   6. 업데이트를 선택합니다.
   7. 에서 플로우 워크플로우 스튜디오로 다시 이동합니다.
8. 플로우에 작업, 하위 플로우 및 플로우 논리를 추가합니다.
9. 플로우를 테스트하려면 테스트 버튼을 클릭합니다.
   테스트 버튼을 클릭하면 플로우에 보낼 메시지를 만들 수 있는 테스트 플로우 대화 상자가 열립니다. 시스템은 Kafka 주제의 메시지가 아니라 새로 생성된 이 메시지로 플로우를 테스트합니다. 플로우는 플로우가 활성화될 때까지 주제에서 메시지 수신을 시작하지 않습니다. 자세한 내용은 플로우 테스트 문서를 참조하십시오.
10. 플로우를 활성화하려면 활성화 버튼을 클릭하십시오.
    플로우를 활성화하면 시스템이 주제에서 메시지를 찾기 시작합니다. 메시지를 수신하려면 플로우를 활성화해야 합니다. 자세한 내용은 플로우 활성화 문서를 참조하십시오.

결과

Kafka 주제에 메시지가 있으면 플로우가 트리거되고 작업을 실행합니다.