스크립트 소비자 구성

스크립트를 사용하여 Kafka 환경에서 데이터를 임포트하고 처리합니다.

시작하기 전에

• 필요한 역할: integration_hub_admin
• 이 소비자는 구독이 Apache Kafka용 스트리밍 연결 필요한 일부입니다Apache Kafka용 스트리밍 연결. 자세한 내용은 https://www.servicenow.com/products/automation-engine.html 문서를 참조하십시오.
• 다음 플러그인이 필요합니다.
  • ServiceNow IntegrationHub Kafka Consumer(com.glide.hub.kafka_consumer) 플러그인
  • IntegrationHub ETL Consumer - Kafka(com.glide.hub.etl_consumer.kafka) 플러그인입니다 ServiceNow .

이 태스크 정보

소비자를 구성하려면 두 개의 기록을 생성해야 합니다.

1. 데이터를 가져오고 처리하는 방법을 지정하는 소비자 기록입니다.
2. 소비자에 대한 데이터 스트림을 정의하는 Kafka 스트림에 대한 기록입니다.

이 작업은 소비자 생성을 다룹니다. Kafka 스트림 생성에 대한 지침은 을 참조하십시오 Kafka 스트림 만들기.

프로시저

1. 다음으로 이동 모두 > 통합 허브 > 소비자 > 스크립트 소비자.
2. 새로 만들기를 선택합니다.
3. 양식에서 필드에 내용을 입력합니다.

   표 1. Kafka 스크립트 소비자

   필드	설명
   이름	스크립트 소비자의 이름입니다.
   납품 보증	노드 오류가 있는 경우 들어오는 메시지에 대한 배달 보장을 지정하는 옵션입니다. 다음 중 하나를 선택하십시오. 손실되었지만 중복되지 않음: 모든 메시지가 한 번 이상 배달되도록 합니다. 일부 메시지는 두 번 이상 배달될 수 있습니다. 한 번 또는 전혀 배달하지 않음: 메시지가 두 번 이상 배달되지 않도록 합니다. 일부 메시지는 전혀 배달되지 않을 수 있습니다.
   이벤트 소비자	Kafka 주제에서 받은 메시지를 사용하는 데 사용할 스크립트입니다.
   애플리케이션	변환 맵 소비자의 애플리케이션 범위입니다.

4. 저장을 선택합니다.

예

이 예제에서는 메시지를 처리하기 위한 샘플 스크립트를 보여 줍니다.

(function process(messages) {
 // Add your code here to consume kafka messages 
 // sample message [ { 'key' : 'message_key' , 'message' : 'message' , 'headers' : [ { 'key' : 'header_key' , 'value' : 'header_value' } ] } ] 

 for (var i = 0; i < messages.length; i++) {
     var message = JSON.parse(messages[i].message);
     gs.info('Number ' + message.number + ', short description ' + message.short_description +
         ', headers ' + JSON.stringify(messages[i].headers));
 }
})(messages);

다음에 수행할 작업

Kafka 스트림 만들기 이 소비자의 경우. 스트림이 활성화되면 Kafka 환경에서 메시지 수신을 시작할 수 있습니다.