변환 맵 소비자 구성

기존 변환 맵 구성을 사용하여 Kafka 환경에서 데이터를 임포트하고 처리합니다.

시작하기 전에

• 필요한 역할: integration_hub_admin
• 이 소비자는 구독이 스트리밍 연결 필요합니다. 자세한 내용은 https://www.servicenow.com/now-platform/workflow-data-fabric.html 문서를 참조하십시오.
• ServiceNow 스트림 연결 설치 관리자 [com.glide.hub.stream_connect.installer] 플러그인이 필요합니다.
• 이 소비자에게는 변환 맵이 필요합니다.

Kafka 메시지 페이로드 포맷

Kafka 메시지에 단순 JSON 페이로드를 사용합니다. 각 Kafka 메시지에는 하나의 플랫 JSON 개체만 있어야 합니다. 목록 및 중첩된 객체가 있는 페이로드와 같은 복합 JSON 페이로드는 지원되지 않습니다.

키-값 쌍의 플랫 맵을 사용하는 간단하고 유효한 JSON 입력의 예입니다.

{"key1": "value1", "key2": "value2"}

복잡하고 잘못된 JSON 입력의 예입니다. 첫 번째는 목록을 사용합니다. 두 번째는 중첩된 객체를 사용합니다.

[{"key1": "value1", "key2": "value2"}, {"key1": "value3", "key2": "value4"}]

{"key1": "value1", "key2": {"key3": "value3", "key4": "value4"}}

이 태스크 정보

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

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

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

프로시저

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

   표 1. 변환 맵 소비자

   필드	설명
   이름	변환 맵 소비자의 이름입니다.
   변환 맵	데이터를 처리하는 데 사용할 변환 맵의 이름입니다.
   제공 보장	노드 오류가 있는 경우 수신 메시지에 대한 배달 보장을 지정하는 옵션입니다. 다음 중 하나를 선택하십시오. 손실은 없지만 중복됨: 모든 메시지는 한 번 이상 전달됩니다. 일부 메시지는 두 번 이상 전달될 수 있습니다. 한 번 또는 전혀 없음: 메시지가 두 번 이상 전달되지 않습니다. 일부 메시지는 전혀 전달되지 않을 수 있습니다.
   직렬화 형식	메시지의 serialization 형식입니다. 다음 중 하나를 선택하십시오. 일반 텍스트: 일반 텍스트 메시지에 대해 이 옵션을 선택합니다. 이것이 기본 형식입니다. 인코딩됨: Avro 형식의 메시지에 Apache 대해 이 옵션을 선택합니다. 일반 텍스트 메시지를 Avro 형식으로 변환하려면 스키마가 필요합니다. 스키마 레지스트리 필드에서 스키마 레지스트리를 선택합니다. 스키마에 대한 자세한 내용은 다음 문서를 참조하십시오 의 스키마 관리 스트리밍 연결.
   열 매핑	메시지의 JSON 키가 데이터를 임포트 세트 테이블의 열 이름 또는 레이블에 매핑할지 여부를 지정하는 옵션입니다. 다음 중 하나를 선택하십시오. 레이블 열 이름
   삽입 동기화	기록 삽입을 동기화하여 고유한 병합 필드 값을 가진 기록이 하나만 남도록 보장하는 옵션입니다.
   애플리케이션	변환 맵 소비자에 대한 애플리케이션 범위입니다.
   스키마 레지스트리	선택한 스키마에 대한 레지스트리입니다. 다음 중 하나를 선택하십시오. 독립 실행형 스키마 레지스트리 융합 스키마 레지스트리 이 필드는 직렬화 형식이인코딩됨으로 설정된 경우에만 나타납니다. 융합 스키마 레지스트리의 경우 받은 메시지의 스키마 ID가 스키마 테이블에 없으면 시스템은 구성된 REST 연결을 사용하여 스키마를 동적으로 임포트합니다.

4. 저장을 선택합니다.

다음에 수행할 작업

Kafka 스트림 생성 이 소비자에 대해. 스트림이 활성화되면 Kafka 환경에서 메시지 수신을 시작할 수 있습니다.