---
sourceDocument: Xanadu 애플리케이션과의 통합 생성
sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/ko-KR/xanadu/integrate-applications

 Release :

    - xanadu

ft:locale :

    - ko-KR

ft:publication_title :

    - Xanadu 애플리케이션과의 통합 생성

ft:clusterId :

    - crint

bundleId :

    - crint

workflow :

    - Creator


---

# Kafka 메시지 트리거 및 스크립트 소비자를 사용하여 메시지 소비

# Kafka 메시지 트리거 및 스크립트 소비자를 사용하여 메시지 소비 {#ariaid-title1}

* 릴리스 버전: Xanadu
* 
* 업데이트 날짜 2024년 08월 01일
* 
* ![](https://www.servicenow.com/docs/portal-asset/ico-clock) 소요 시간: 4분

Kafka 메시지 트리거와 스크립트 소비자가 있는 워크플로우 스튜디오 Hermes에서 메시지를 검색합니다.

## 시작하기 전에

* 필요한 역할: integration_hub_admin
* 이 페이지는 [스트리밍 연결 퀵 스타트 가이드](https://servicenow-prod.fluidtopics.net/J5qO5LL7rS1G0OAxgue_hA "이 빠른 시작 가이드에서는 6개의 Stream Connect 생산자 및 소비자를 각각 설정하고 사용하여 인스턴스와 Kafka 환경 간에 ServiceNow 데이터를 교환하는 방법에 대한 개요를 제공합니다.")의 일부입니다.
* 이 문서에서는 Hermes에 대한 연결을 통해 메시지를 소비하는 방법을 보여줍니다. 연결을 설정하고 테스트하려면 [ADCv2 게이트웨이를 통한 Hermes 연결 테스트를](https://servicenow-prod.fluidtopics.net/3wrWIFfG2DcBeEP4efSvyg "ADCv2 게이트웨이를 통해 Hermes에 대한 연결을 테스트하여 키 저장소 및 신뢰 저장소가 올바르게 생성되었는지 확인합니다.") 참조하세요[Set up a secure connection to the Hermes Messaging Service](https://www.servicenow.com/docs/access?context=set-up-secure-connection-to-hermes&version=xanadu&pubname=xanadu-servicenow-platform&ft:locale=en-US).
* 이 페이지의 첫 번째 부분에서는 Kafka 메시지 트리거를 사용하여 워크플로우 스튜디오 메시지를 사용하는 방법을 보여 줍니다. 트리거에 대한 자세한 내용은 을 참조하십시오 [Create a flow with a Kafka Message trigger](https://www.servicenow.com/docs/access?context=create-flow-kafka&version=xanadu&pubname=xanadu-build-workflows&ft:locale=en-US). 플로우 구성 및 방법에 대한 워크플로우 스튜디오 자세한 내용은 을 참조하십시오 .
* 이 페이지의 두 번째 부분에서는 스크립트 소비자를 사용하여 메시지를 사용하는 방법을 보여 줍니다. 자세한 내용은 [스크립트 소비자 구성](https://servicenow-prod.fluidtopics.net/Nw8zReDoo2F~RKDirPDIEA "스크립트를 사용하여 Kafka 환경에서 데이터를 임포트하고 처리합니다.") 문서를 참조하십시오.
{#use-kafka-trigger-script-consumer__ul_gbw_h5n_cyb}

## 프로시저

1. 메시지를 소비할 주제를 만듭니다.
   1. 다음 명령을 사용하여 Hermes에서 주제를 만듭니다.  

          bin/kafka-topics.sh --create --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002, <instance name>.service-now.com:4003 --topic snc.<instance name>.topic1

      `<instance name>`을 인스턴스의 이름으로 바꿔야 합니다.
   2. 주제를 보려면 인스턴스에 로그인한 후 모두통합 허브스트림 커넥트주제.  
      주:  
      주제를 생성하는 데 약 10분이 걸립니다.
   {#use-kafka-trigger-script-consumer__substeps_ir5_fzd_yxb}
2. 주제의 메시지를 사용하는 플로우 트리거를 생성합니다.
   1. 다음으로 이동 모두프로세스 자동화플로우 디자이너.
   2. 선택 새로 생성플로우.
   3. 플로우 속성 양식에서 플로우 이름을 입력한 후 Submit을 입력합니다.  
      이 예에서는 <kbd class="ph userinput">Topic1 Consumer</kbd>라는 이름을 사용합니다.
   4. 트리거 섹션에서 트리거 추가를 선택한 다음, 트리거 유형으로 Kafka 메시지를 선택합니다.  
   5. Topic1 주제를 선택합니다.  

      돋보기 아이콘을 사용하여 사용 가능한 주제 목록을 볼 수 있습니다.
   6. 플로우의 동작 섹션에서 작업, 플로우 논리 또는 하위 플로우 추가플로우 논리For Each.
   7. 메시지 데이터 알약을 항목 필드로 끈 다음, 완료를 선택합니다.
   8. 플로우의 동작 섹션에서 작업, 플로우 논리 또는 하위 플로우 추가작업ServiceNow 코어로그.
   9. 페이로드 데이터 알약을 메시지 필드로 끌어온 다음 완료를 선택합니다.  
   10. 흐름 트리거를 저장합니다.
   11. 이 플로우에 대한 보고를 활성화하려면 설정 \[sys_flow_execution_setting\] 테이블로 이동하십시오.
   12. 새 항목을 만들고 위에서 생성한 플로우에 대한 보고를 사용 설정합니다.  
   13. 플로우로 다시 이동하여 활성화를 선택합니다.
   14. 주제 구독을 보려면 다음으로 이동하십시오. 모두통합 허브스트림 커넥트구독.  
   {#use-kafka-trigger-script-consumer__substeps_vrn_szd_yxb}
3. Kafka 명령줄 도구를 사용하여 주제에 메시지를 게시합니다.
   1. 다음 명령을 실행하여 주제에 메시지를 게시합니다.  

          bin/kafka-console-producer.sh --topic snc.<instance name>.topic1  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003

      `<instance name>`을 인스턴스의 이름으로 바꿔야 합니다.  
      이 명령은 메시지를 입력하라는 메시지를 표시합니다. 몇 가지 샘플 메시지를 추가합니다. 이 예제에서는 다음 메시지를 사용합니다.
      * 테스트 메시지 1
      * 테스트 메시지 2
      * 테스트 메시지 3
      {#use-kafka-trigger-script-consumer__ul_arc_54m_2yb}약 1분 후에 메시지를 받게 됩니다.
   2. 플로우로 다시 이동하여 실행을 선택합니다.  
   3. 플로우 실행을 엽니다.  
   4. 이 구독에 대한 통계를 보려면 다음으로 이동하십시오. 모두통합 허브스트림 커넥트구독에서 구독을 열고 통계 보기로 이동합니다.  
   {#use-kafka-trigger-script-consumer__substeps_nrq_gkq_yxb}
4. 주제의 메시지를 소비하는 스크립트 소비자를 생성합니다.
   1. 다음으로 이동 통합 허브소비자스크립트 소비자.
   2. 새로 만들기를 선택합니다.
   3. 이름 필드에 스크립트 소비자의 이름을 입력합니다.  
      이 예시에서는 <kbd class="ph userinput">Topic1 Consumer</kbd>를 사용합니다.
   4. 스크립트 상자에 다음 논리를 추가하여 메시지를 기록할 스크립트를 설정합니다.  

          for (var i = 0; i < messages.length; i++) {
                gs.info('Received message ' + JSON.stringify(messages[i].message));
           }

   5. 양식을 저장합니다.
   6. 관련 링크 섹션에서 새로 만들기 를 선택하여 메시지를 사용할 Kafka 스트림을 추가합니다.
   7. Kafka 스트림 양식에서 다음 필드 값을 설정합니다.  
      * <kbd class="ph userinput">Topic1 스트림</kbd>의 이름입니다.
      * 앞서 생성한 주제인 topic1에 대한 주제입니다.
      * 최대 동시성은<kbd class="ph userinput">1</kbd>입니다.
      * 토픽에 저장된 모든 메시지를소비 시작합니다. 이 옵션을 사용하면 이 주제에 이미 게시된 메시지를 읽을 수 있습니다.
      * 자동으로 최적화하는 메시지 처리.
      {#use-kafka-trigger-script-consumer__ul_pbp_rqm_2yb}  
   8. 관련 링크 아래에서 활성화 링크를 선택합니다.  
      활성화된 구독을 볼 수 있어야 합니다.
   9. 메시지를 보려면 다음으로 이동합니다. 모두시스템 로그시스템 로그 을 클릭하고 받은 메시지로 시작하는 메시지를 필터링합니다.  
   10. 1분 후에 모든 메시지가 표시되어야 합니다.
   {#use-kafka-trigger-script-consumer__substeps_mm5_rkq_yxb}

## 다음에 수행할 작업

[ETL 및 변환 맵 소비자를 사용하여 데이터 임포트](https://servicenow-prod.fluidtopics.net/Zn1XD5mg6zpwhBOrcVgvDQ "ETL 정의 및 변환 맵을 사용하여 Kafka 이벤트를 처리합니다. ETL 정의 및 변환 맵은 예약된 임포트를 통해 데이터를 끌어올 때 사용할 변환 논리를 지정합니다. 동일한 ETL 정의 및 변환 맵을 사용하여 Kafka를 통해 수신된 이벤트를 변환할 수 있습니다.").