변환 맵 소비자 구성

  • 릴리스 버전: Washingtondc
  • 업데이트 날짜 2024년 02월 01일
  • 읽기1분

    • 기존 변환 맵 구성을 사용하여 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 변환 맵 소비자
      필드 설명
      이름 변환 맵 소비자의 이름입니다.
      변환 맵 데이터를 처리하는 데 사용할 변환 맵의 이름입니다.
      납품 보증 노드 오류가 있는 경우 들어오는 메시지에 대한 배달 보장을 지정하는 옵션입니다. 다음 중 하나를 선택하십시오.
      • 손실되었지만 중복되지 않음: 모든 메시지가 한 번 이상 배달되도록 합니다. 일부 메시지는 두 번 이상 배달될 수 있습니다.
      • 한 번 또는 전혀 배달하지 않음: 메시지가 두 번 이상 배달되지 않도록 합니다. 일부 메시지는 전혀 배달되지 않을 수 있습니다.
      열 매핑 메시지의 JSON 키가 데이터를 임포트 세트 테이블의 열 이름 또는 레이블에 매핑할지 여부를 지정하는 옵션입니다. 다음 중 하나를 선택하십시오.
      • 레이블
      • 열 이름
      삽입 동기화 기록 삽입을 동기화하여 고유한 병합 필드 값이 있는 기록이 하나만 있도록 보장하는 옵션입니다.
      애플리케이션 변환 맵 소비자의 애플리케이션 범위입니다.
    4. 저장을 선택합니다.

    다음에 수행할 작업

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