ServiceNow Kafka 소비자 구성

지정된 주제와 관련된 이벤트를 검색하여 필수 ServiceNow 테이블에 저장합니다.

시작하기 전에

• 구독을 요청합니다 통합 허브 .
• 을 활성화하고 설정합니다 융합 Kafka REST 프록시 스포크.
• 를 활성화합니다 ServiceNow Kafka 소비자.
• 엔터티 및 엔터티 간 매핑을 정의합니다. 자세한 내용은 강력한 임포트 세트 변환기를 참조하십시오.
• 필요한 역할: import_admin

프로시저

1. 다음으로 이동 모두 > 프로세스 자동화 > Kafka 소비자.
2. 새로 만들기를 클릭합니다.
3. 양식에서 다음 값을 입력합니다.

   필드	설명
   이름	기록을 식별하는 이름입니다.
   브로커 연결 별칭	의 연결 별칭입니다 융합 Kafka REST 프록시 스포크.
   주제	이벤트를 검색할 주제입니다.
   강력한 변환기 정의	테이블의 이벤트 변환 및 데이터 저장에 사용되는 강력한 변환기 정의입니다 ServiceNow . 자세한 내용은 강력한 임포트 세트 변환기를 참조하십시오.
   오프셋 시작점	Kafka Consumer auto.offset.reset의 값입니다. 이는 초기 오프셋이 없거나 현재 오프셋이 서버에 더 이상 존재하지 않는 경우 Kafka 소비자가 수행해야 하는 작업을 지정합니다. 자세한 내용은 Kafka 2.7 설명서 를 참조하십시오.
   그룹당 파티션	소비자 스레드당 파티션 수입니다.
   페이지 크기(바이트)	요청의 최대 크기입니다.
   페이지 제한	반복당 최대 요청 수입니다.
   포함된 형식	주제에 대한 Kafka 메시지의 형식입니다.
   요청 시간 제한(밀리초)	Kafka 소비자 consumer.request.timeout.ms 의 값입니다. 클라이언트가 요청의 응답을 기다리는 최대 시간을 지정합니다. 자세한 내용은 Kafka 2.7 설명서 를 참조하십시오.
   변환 오류 시 중지	변환 오류가 발생할 때 수신을 중지하는 옵션입니다.
   자세한 변환	임포트한 모든 이벤트를 임포트 세트에 기록하고 변환을 위한 추가 디버그 로그를 생성하는 옵션입니다.

   주:

   각 주제에 대해 하나의 Kafka Consumer 기록을 생성해야 합니다.
4. 싱크 수신기 시작 관련 링크를 클릭합니다.
   Kafka 파티션 그룹 수신기 상태 테이블은 주제 파티션 데이터로 채워집니다.
5. 옵션: 수신을 중지하려면 싱크 수신기 시작 관련 링크를 클릭합니다.
6. 다음으로 이동 시스템 스케줄러 > 예약된 작업.
7. 기록, Kafka 소비자 트리거를 엽니다.
8. 트리거 유형 목록에서 간격을 선택합니다.
9. 업데이트를 클릭합니다.