스트리밍 연결 퀵 스타트 가이드

릴리스 버전: Australia

업데이트 날짜 2026년 03월 12일

소요 시간: 21분

이 빠른 시작 안내서는 인스턴스와 Kafka 환경 간에 ServiceNow 데이터를 교환하기 위해 6개의 Stream Connect 생산자와 소비자를 각각 설정하고 사용하는 방법에 대한 개요를 제공합니다.

스트림 커넥트에는 Kafka 환경으로 ServiceNow 데이터를 보내는 두 개의 생산자가 있습니다.

워크플로우 스튜디오의 Kafka 생산자 단계
ProducerV2 API

또한 스트림 커넥트에는 Kafka 환경에서 데이터를 검색하는 4개의 소비자가 있습니다.

워크플로우 스튜디오의 Kafka 메시지 트리거
ETL(변환 로드) 소비자 추출
변환 맵 소비자
스크립트 소비자

인스턴스를 ServiceNow Kafka 환경에 연결하기 위해 스트림 커넥트 Hermes 메시징 서비스는 . 다음 다이어그램에서는 각 생산자와 소비자, 그리고 이들이 Hermes를 통해 Kafka 환경(여기에 고객 사이트로 표시됨)에 연결하는 방법을 보여줍니다.

스트림 커넥트 생산자와 소비자를 보여주는 다이어그램으로, 이들이 을 통해 "고객 사이트"라고 하는 Kafka 환경에 연결하는 방법을 보여줍니다.Hermes 메시징 서비스 — 그림 1. 스트림 커넥트 생산자 및 소비자

자세한 내용은 및 문서를 참조하십시오Apache Kafka용 스트리밍 연결 사용.

시작

고객 사이트를 나타내기 위해 이 가이드에서는 컴퓨터에서 실행되는 명령줄 도구를 사용합니다 Apache Kafka . 이 도구에 사용되는 구성 매개변수는 Kafka 프로토콜을 사용하여 ADCv2(Application Delivery Controller, 버전 2) 게이트웨이에 대한 클라이언트 연결을 구성하는 데 사용할 수 있습니다.

주어진 모든 명령은 OpenSSL 버전(LibreSSL 2.8.3) 및 Apache Kafka 바이너리 배포 버전 kafka_2.13-3.4.0.tgz로 테스트되었습니다. 그러나 모든 명령은 로컬 환경에 있는 모든 버전에서 작동해야 합니다.

빠른 시작 단계

이 빠른 시작 가이드는 5단계로 구성됩니다. 1단계와 2단계에서는 Hermes에 대한 연결을 설정하고 테스트하는 방법을 다룹니다. 3-5단계에서는 데이터를 보내고 받기 위해 각 스트림 커넥트 생산자와 소비자를 구성하고 사용하는 방법을 보여 줍니다.

ADCv2 게이트웨이는 상호 인증을 사용하여 요청을 인증하므로 첫 번째 단계는 즐겨 사용하는 Kafka 클라이언트와 함께 사용할 키 저장소와 신뢰 저장소를 만드는 것입니다. 다음 페이지에서는 필요한 인증서를 Hermes 메시징 서비스에 대한 보안 연결 설정생성하는 방법을 보여줍니다.
Hermes에 대한 보안 연결을 설정한 후 ADCv2 게이트웨이를 통해 Hermes에 대한 연결을 테스트하여 키 저장소 및 신뢰 저장소가 올바르게 생성되었는지 확인합니다.
이제 할 수 있습니다 Kafka 메시지 트리거 및 스크립트 소비자를 사용하여 메시지 소비. 이 페이지의 첫 번째 부분에서는 Kafka 메시지 트리거 워크플로우 스튜디오 를 사용하여 Kafka에서 메시지를 검색하는 방법을 보여줍니다. 두 번째 부분에서는 스크립트 소비자를 사용하여 메시지를 검색하는 방법을 보여줍니다.
그리고 ETL 및 변환 맵 소비자를 사용하여 데이터 임포트. ETL 정의 및 변환 맵은 예약된 임포트를 통해 데이터를 끌어올 때 사용할 변환 논리를 지정합니다. 동일한 ETL 정의 및 변환 맵을 사용하여 Kafka를 통해 수신된 이벤트를 변환할 수 있습니다.
주:
ETL 소비자를 사용하려면 강력한 임포트 세트 변환기가 필요합니다. 마찬가지로 변환 맵 소비자를 사용하려면 변환 맵이 필요합니다.
마지막으로 Kafka 생산자 단계 및 ProducerV2 API를 사용하여 메시지 게시. 이 페이지에서는 Kafka Producer 단계와 워크플로우 스튜디오 ProducerV2 API를 모두 사용하여 Kafka에 메시지를 푸시하는 방법을 보여줍니다.

Hermes 메시징 서비스에 대한 보안 연결 설정

인스턴스 서명 인증서를 생성 ServiceNow® 하여 Kafka 주제를 보호합니다.

시작하기 전에

설정하려면 Hermes 메시징 서비스 네트워크 관리자 및 Kafka 관리자와의 조정이 필요합니다. 네트워크 관리자와 협력하여 필요한 보안 인증서를 얻고 필요한 포트를 엽니다. Kafka 관리자와 협력하여 Kafka 환경이 올바르게 구성되어 있는지, 애플리케이션이 표준 Kafka 프로토콜을 사용하여 연결할 Hermes 메시징 서비스 수 있는지 확인합니다.

다음 설정이 제대로 되어 있는지 확인합니다.

이(가) Hermes 메시징 서비스 활성화됩니다. 문서를 참조하십시오.
Key Management Framework 플러그인(com.glide.kmf.global)이 활성화됩니다.
인증서 [sys_kmf_certificate] 테이블에는 인스턴스 루트 CA 인증서가 포함되어 있습니다 ServiceNow .
인스턴스가 사용자 지정 URL로 구성되지 않았습니다. 인스턴스 PKI 인증서 생성기에는 사용자 지정 URL이 지원되지 않습니다.

필요한 역할: hermes_admin, sn_kmf.cryptographic_manager 또는 admin

KMF 역할 할당에 대한 자세한 내용은 다음 문서를 참조하십시오 .

프로시저

다음으로 이동 모두 > 인증서 생성기 > 인스턴스 PKI 인증서 생성기.

옵션: 네임스페이스 또는 주제 수준에서 ACL(접근 제어 목록)을 구성하여 주제에 대한 액세스를 제어합니다.

옵션	설명
네임스페이스에 ACL 적용	ACL 구성을 선택합니다. 주제 ACL 대화 상자에서 네임스페이스를 선택합니다. 구성할 네임스페이스를 입력합니다. 읽기 전용 또는 읽기/쓰기를 선택하여 권한 수준을 설정합니다. 추가를 선택합니다.
정의된 주제에 ACL 적용	ACL 구성을 선택합니다. 주제 ACL 대화 상자에서 정의된 주제를 선택합니다. 구성하려는 기존 주제를 입력합니다. 읽기 전용 또는 읽기/쓰기를 선택하여 권한 수준을 설정합니다. 추가를 선택합니다.

인증서 전달자에게는 네임스페이스의 주제 또는 선택한 기존 주제에 대한 읽기 또는 읽기/쓰기 접근 권한이 부여됩니다.

Hermes 메시징 서비스에 대한 보안을 설정합니다.
1. 인스턴스 PKI 인증서 생성기 페이지로 다시 이동합니다.
2. 인증서 암호 필드에 키 저장소 암호를 입력합니다.
3. 생성을 선택합니다.
시스템은 인증서 [sys_kmf_certificate] 테이블에서 인스턴스 서명 인증서를 생성하고, 키 스토어를 생성하고, 신뢰 스토어를 생성합니다.
IPKI 인증서 생성기에 대해 제한된 호출자 접근이 허용되지 않는 경우 교차 범위 접근 오류가 나타납니다. 제한된 호출자 접근 허용에 대한 지원이 필요한 경우 연락처에 문의하십시오 고객 서비스 및 지원 . 이 문제를 해결하려면 고객 서비스 및 지원 제한된 호출자 접근 권한 [sys_restricted_caller_access] 테이블에서 source_scope=76f9d51369115083f4ea77aab1677cc0을 참조할 수 있습니다.
키 저장소 다운로드를 선택하여 키 저장소의 사본을 저장합니다.
신뢰 저장소 다운로드를 선택하여 신뢰 저장소의 복사본을 저장합니다.
키 저장소 및 신뢰 저장소 파일을 에 연결할 각 생산자 및 소비자 클라이언트에 복사합니다 Hermes 메시징 서비스.

결과

이제 에 대한 Hermes 메시징 서비스보안 연결을 만들 수 있습니다.

주:

인스턴스 PKI 인증서 생성기를 사용하여 생성한 키 스토어를 사용하여 연결 Hermes해야 합니다. 설명서에 따라 ServiceNow 생성되지 않은 사용자 지정 생성 키 스토어는 지원되지 않습니다.

ADCv2 게이트웨이를 통해 Hermes에 대한 연결 테스트

ADCv2 게이트웨이를 통해 Hermes에 대한 연결을 테스트하여 키 저장소와 신뢰 저장소가 올바르게 생성되었는지 확인합니다.

시작하기 전에

필요한 역할: integration_hub_admin

프로시저

를 다운로드하여 설치 Apache Kafka합니다.
1. 다운로드 Apache Kafka 바이너리.
2. 다음 명령을 실행하여 Kafka 패키지의 압축을 풉니다.
```
tar -zxvf kafka_2.13-3.1.2.tgz
```
다음 명령을 실행하여 Kafka 디렉터리로 이동합니다.
```
cd kafka_2.13-3.1.2
```
생산자를 구성합니다.
1. config/producer.properties 파일을 엽니다.
2. 다음 SSL 속성을 구성합니다.
```
security.protocol=SSL

ssl.truststore.password=<truststore password>

ssl.truststore.location=<path to truststore.p12>

ssl.truststore.type=PKCS12

ssl.keystore.password=<keystore password>

ssl.keystore.location=<path to keystore.p12>

ssl.keystore.type=PKCS12

ssl.key.password=<keystore password>
```
  다음 자리표시자 변수를 대체합니다.
  - <신뢰 저장소 암호> 를 신뢰 저장소 암호로 바꿉니다.
  - <truststore.p12 경로> 신뢰 저장소 파일의 경로로 저장합니다.
  - <키 저장소 암호> 를 키 저장소 암호로 바꿉니다.
  - <keystore.p12 경로> 를 키 스토어 파일의 경로로 바꿉니다.
1-3단계를 수행한 후 producer.properties를 올바르게 다운로드 Apache Kafka 하고 구성했어야 합니다. 다음 단계에서 제공하는 모든 명령은 홈 디렉터리 내에서 Apache Kafka 실행되어야 합니다.
config/producer.properties 파일을 config/bootcamp.properties에 복사합니다.
이 예에서는 bootcamp 를 일반 이름으로 사용합니다.
```
cp config/producer.properties config/bootcamp.properties
```

다음 명령을 사용하여 주제를 나열합니다.

bin/kafka-topics.sh --list --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

<인스턴스 이름>을 인스턴스 이름으로 바꿔야 합니다.

인스턴스에 주제가 있는 경우 여기에 나열해야 합니다.

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

Kafka 메시지 트리거 및 스크립트 소비자를 워크플로우 스튜디오 사용하여 Hermes에서 메시지를 검색합니다.

시작하기 전에

필요한 역할: integration_hub_admin
이 섹션의 첫 번째 부분에서는 에서 Kafka 메시지 트리거 워크플로우 스튜디오 를 사용하여 메시지를 사용하는 방법을 보여줍니다. 이 트리거에 대한 자세한 내용은 다음 문서를 참조하십시오 .
이 섹션의 두 번째 부분에서는 스크립트 소비자를 사용하여 메시지를 사용하는 방법을 보여줍니다. 자세한 내용은 스크립트 소비자 구성 문서를 참조하십시오.

프로시저

메시지를 사용할 주제를 생성합니다.
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
```
  <인스턴스 이름>을 인스턴스 이름으로 바꿔야 합니다.
2. 주제를 보려면 인스턴스에 로그인하여 다음으로 이동합니다. 모두 > 통합 허브 > 스트림 커넥트 > 주제.
  
  주:
  주제를 생성하는 데 약 10분이 걸립니다.
주제의 메시지를 사용하도록 플로우 트리거를 생성합니다.
1. 다음으로 이동 모두 > 프로세스 자동화 > 플로우 디자이너.
2. 선택 새로 생성 > 플로우.
3. 플로우 속성 양식에서 플로우의 이름을 입력한 다음 제출을 입력합니다.
  이 예시에서는 Topic1 Consumer라는 이름을 사용합니다.
4. 트리거 섹션에서 트리거 추가를 선택한 다음, 트리거 유형으로 Kafka 메시지를 선택합니다.
5. 주제1 주제를 선택합니다.
  
  돋보기 아이콘을 사용하여 사용 가능한 주제 목록을 볼 수 있습니다.
6. 플로우의 작업 섹션에서 작업, 플로우 논리 또는 하위 플로우 추가 > 플로우 논리 > 각각에 대해.
7. 메시지 데이터 알약을 항목 필드로 끌어간 다음 완료를 선택합니다.
8. 플로우의 작업 섹션에서 작업, 플로우 논리 또는 하위 플로우 추가 > 작업 > ServiceNow 코어 > 로그.
9. 페이로드 데이터 알약을 메시지 필드로 끌어다 놓은 다음, 완료를 선택합니다.
10. 플로우 트리거를 저장합니다.
11. 설정 [sys_flow_execution_setting] 테이블로 이동하여 이 플로우에 대한 보고를 활성화합니다.
12. 새 항목을 만들고 위에서 생성한 플로우에 대한 보고를 활성화합니다.
13. 플로우로 돌아가서 활성화를 선택합니다.
14. 토픽 구독을 보려면 다음으로 이동하십시오. 모두 > Integration Hub > 스트림 커넥트 > 구독.
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
```
  <인스턴스 이름>을 인스턴스 이름으로 바꿔야 합니다.
  이 명령은 메시지를 묻는 메시지를 표시합니다. 몇 가지 샘플 메시지를 추가합니다. 이 예시에서는 다음 메시지를 사용합니다.
  - 테스트 메시지1
  - 테스트 메시지2
  - 테스트 메시지3
  약 1분 후에 메시지를 받게 됩니다.
2. 플로우로 돌아가 실행을 선택합니다.
3. 플로우 실행을 엽니다.
4. 이 구독에 대한 통계를 보려면 다음으로 이동하십시오. 모두 > Integration Hub > 스트림 커넥트 > 구독에서 구독을 연 다음 통계 보기로 이동합니다.
주제의 메시지를 사용할 스크립트 소비자를 만듭니다.
1. 다음으로 이동 통합 허브 > 소비자 > 스크립트 소비자.
2. 새로 만들기를 선택합니다.
3. 이름 필드에 스크립트 소비자의 이름을 입력합니다.
  이 예시에서는 Topic1 Consumer를 사용합니다.
4. 스크립트 상자에 다음 논리를 추가하여 메시지를 기록하도록 스크립트를 설정합니다.
```
for (var i = 0; i < messages.length; i++) {
      gs.info('Received message ' + JSON.stringify(messages[i].message));
 }
```
5. 양식을 저장합니다.
6. 관련 링크 섹션에서 새로 만들기 를 선택하여 메시지를 사용할 Kafka 스트림을 추가합니다.
7. Kafka 스트림 양식에서 다음 필드 값을 설정합니다.
  - Topic1 스트림에 대한 이름.
  - 이전에 생성된 주제 topic1에 대한 주제입니다.
  - 최대 동시 허용 사용자 수는1입니다.
  - 에 소비 시작주제에 저장된 모든 메시지입니다. 이 옵션을 사용하면 이 주제에 이미 게시된 메시지를 읽을 수 있습니다.
  - 자동으로 최적화하기 위한 메시지 처리입니다.
8. 관련 링크에서 활성화 링크를 선택합니다.
  활성화된 구독을 볼 수 있어야 합니다.
9. 메시지를 보려면 다음으로 이동하십시오. 모두 > 시스템 로그 > 시스템 로그 수신됨 메시지로 시작하는 메시지를 필터링합니다.
10. 1분 후에 모든 메시지가 표시됩니다.

ETL 및 변환 맵 소비자를 사용하여 데이터 임포트

ETL 정의 및 변환 맵을 사용하여 Kafka 이벤트를 처리합니다. ETL 정의 및 변환 맵은 예약된 임포트를 통해 데이터를 끌어올 때 사용할 변환 논리를 지정합니다. 동일한 ETL 정의 및 변환 맵을 사용하여 Kafka를 통해 수신된 이벤트를 변환할 수 있습니다.

시작하기 전에

필요한 역할: integration_hub_admin
이 섹션의 첫 번째 부분에서는 ETL 소비자를 사용하여 메시지를 사용하는 방법을 보여줍니다. ETL 소비자를 사용하려면 강력한 임포트 세트 변환기가 필요합니다.
이 섹션의 두 번째 부분에서는 변환 맵 소비자를 사용하여 메시지를 사용하는 방법을 보여줍니다. 변환 맵 소비자를 사용하려면 변환 맵이 필요합니다.

프로시저

ETL 및 변환 맵 소비자 메시지를 사용할 주제를 생성합니다.
1. 다음 명령을 사용하여 Hermes에서 주제를 생성합니다.
  이 예에서 주제 이름은 topic2입니다.
```
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>.topic2
```
  <인스턴스 이름>을 인스턴스 이름으로 바꿔야 합니다.
2. 주제를 보려면 인스턴스에 로그인하여 다음으로 이동합니다. 모두 > 통합 허브 > 스트림 커넥트 > 주제.
  
  주:
  주제를 생성하는 데 약 10분이 걸립니다.
주제에서 데이터를 사용할 ETL 소비자를 생성합니다.
1. 다음으로 이동 모두 > 통합 허브 > 소비자 > ETL 소비자.
2. 새로 만들기를 선택합니다.
3. Kafka 소비자 양식에서 이름 필드에 이름을 입력합니다.
  이 예시에서는 구성원 임포트라는 이름을 사용합니다.
4. 강력한 임포트 세트 변환기 필드의 경우 기존 강력한 임포트 세트 변환기를 선택합니다.
  강력한 임포트 세트 변환기의 경우, 단일 열에 데이터를 저장하는 옵션을 사용하지 않는 변환기를 선택합니다. 메시지를 볼 수 있도록 강력한 임포트 세트 변환기에 자세한 정보 표시 옵션이 활성화되어 있는지 확인하십시오.
5. 단일 열의 데이터 옵션을 선택 취소합니다.
  이 옵션은 단일 열에 데이터가 있는 임포트 세트 테이블에 대해서만 선택해야 합니다.
6. 열 매핑을레이블로 설정합니다.
  
  즉, 입력 메시지의 JSON 키가 임포트 세트 테이블의 열 레이블에 매핑됩니다.
7. 양식을 저장합니다.
8. Kafka 스트림 생성 소비자용.
9. Kafka 스트림 양식에서 다음 필드 값을 설정합니다.
  - 주제2 스트림에 대한 이름입니다.
  - 이전에 생성된 주제 topic2에 대한 주제입니다.
  - 최대 동시 허용 사용자 수는1입니다.
  - 소비 시작 대상 첫 번째 활성화 이후에 받은 메시지입니다.
  - 자동으로 최적화하기 위한 메시지 처리입니다.
10. 관련 링크에서 활성화 링크를 선택합니다.
  
  활성화된 구독을 볼 수 있어야 합니다.
topic2에 메시지 게시.
1. 다음 명령을 실행하여 topic2에 메시지를 게시합니다.
```
bin/kafka-console-producer.sh --topic snc.<instance name>.topic2  --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
```
  <인스턴스 이름>을 인스턴스 이름으로 바꿔야 합니다.
  
  이 명령은 메시지를 묻는 메시지를 표시합니다.
2. 다음 JSON 메시지를 전송합니다.
```
{"city":"San Diego","name":"Jhon","id":"SN001","state":"California"}
```
  이 메시지는 임의의 값으로 보낼 수 있지만 JSON 메시지 키는 임포트 세트 테이블 레이블과 일치해야 합니다.
3. 생성한 ETL 소비자로 다시 이동합니다.
  
  약 1분 후에 임포트 세트를 통해 데이터가 임포트되었어야 합니다.
4. 임포트 세트에 대한 자세한 정보를 보려면 임포트 세트 번호를 선택합니다.
5. 임포트 세트 행에 대한 자세한 정보를 보려면 임포트 세트 행 번호를 선택합니다.
데이터를 사용할 변환 맵 소비자를 생성합니다.
1. 다음으로 이동 모두 > 통합 허브 > 소비자 > 변환 맵 소비자.
2. 새로 만들기를 선택합니다.
3. 변환 맵 소비자 양식에서 이름 필드에 이름을 입력합니다.
4. 변환 맵 필드에서 기존 변환 맵을 선택합니다.
5. 양식을 저장합니다.
6. Kafka 스트림 생성 소비자용.
7. Kafka 스트림 양식에서 다음 필드 값을 설정합니다.
  - 맵 스트림을 변환할 이름입니다.
  - 이전에 생성된 주제 topic2에 대한 주제입니다.
  - 최대 동시 허용 사용자 수는1입니다.
  - 소비 시작 대상 첫 번째 활성화 이후에 받은 메시지입니다.
  - 자동으로 최적화하기 위한 메시지 처리입니다.
8. 관련 링크에서 활성화 링크를 선택합니다.
  
  활성화된 구독을 볼 수 있어야 합니다.
topic2에 메시지 게시.
1. 다음 명령을 실행하여 topic2에 메시지를 게시합니다.
```
bin/kafka-console-producer.sh --topic snc.<instance name>.topic2  --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
```
  <인스턴스 이름>을 인스턴스 이름으로 바꿔야 합니다.
  
  이 명령은 메시지를 묻는 메시지를 표시합니다.
2. 다음 JSON 메시지를 전송합니다.
```
{"city":"San Diego","name":"Jhon","id":"SN001","state":"California"}
```
  이 메시지는 임의의 값으로 보낼 수 있지만 JSON 메시지 키는 임포트 세트 테이블 레이블과 일치해야 합니다.
3. 생성한 변환 맵 소비자로 이동합니다.
  약 1분 후에 임포트 세트를 통해 데이터가 임포트되었어야 합니다.
4. 임포트 세트에 대한 자세한 정보를 보려면 위의 3d단계에서와 같이 임포트 세트 번호를 선택합니다.

Kafka 생산자 단계 및 ProducerV2 API를 사용하여 메시지 게시

Kafka 소비자가 읽을 수 있도록 Hermes로 ServiceNow 데이터를 푸시합니다.

시작하기 전에

필요한 역할: integration_hub_admin
이 섹션의 첫 번째 부분에서는 Kafka Producer 단계를 워크플로우 스튜디오 사용하여 Hermes에 메시지를 게시하는 방법을 보여줍니다. 이 단계에 대한 자세한 내용은 다음 문서를 참조하십시오 .
이 섹션의 두 번째 부분에서는 ProducerV2 API를 사용하여 메시지를 게시하는 방법을 보여줍니다. 자세한 내용은 ProducerV2 API를 참조하세요.
모든 메시지를 받으려면 서로 다른 데이터센터에 대해 두 소비자를 실행해야 합니다. 자세한 내용은 문서를 참조하십시오.

프로시저

두 소비자가 메시지를 수신하도록 시작합니다.

명령줄에서 다음 명령을 실행하여 메시지를 받습니다.

bin/kafka-console-consumer.sh --consumer.config config/bootcamp.properties --topic snc.<instance name>.topic1 --group snc.<instance name>.consumer_group1 --from-beginning --bootstrap-server <instance name>.service-now.com:4100,<instance name>.service-now.com:4101,<instance name>.service-now.com:4102,<instance name>.service-now.com:4103

bin/kafka-console-consumer.sh --consumer.config config/bootcamp.properties --topic snc.<instance name>.topic1 --group snc.<instance name>.consumer_group1 --from-beginning --bootstrap-server <instance name>.service-now.com:4200, <instance name>.service-now.com:4201, <instance name>.service-now.com:4202, <instance name>.service-now.com:4203

<인스턴스 이름>을 인스턴스 이름으로 바꿔야 합니다.

플로우 단계를 사용하여 인스턴스에서 메시지를 게시합니다.
1. 다음으로 이동 모두 > 프로세스 자동화 > 플로우 디자이너.
2. 선택하여 새 작업 생성 새로 생성 > 동작.
3. 작업 속성 양식에서 작업에 이름을 지정한 다음 제출을 선택합니다.
  이 예시에서는 메시지 게시자라는 이름을 사용합니다.
4. 작업에 Kafka 생산자 단계를 추가합니다.
  
  작업 단계를 추가하려면 작업 개요에서 입력과오류 평가 사이의 더하기 기호를 선택합니다.
5. 이 단계에서 주제 필드를 topic1로 설정합니다.
6. 메시지 필드에 메시지를 입력합니다.
  
  다른 필드는 변경할 필요가 없습니다.
7. 저장을 선택하여 작업을 저장합니다.
8. 테스트 버튼을 선택하여 작업을 테스트합니다.
  작업을 테스트하면 메시지가 주제에 게시됩니다.
9. 메시지를 보려면 1단계에서 만든 명령줄 콘솔로 이동합니다.
  메시지는 터미널 중 하나에 있어야 합니다.
스크립트를 사용하여 인스턴스에서 메시지를 게시합니다.
1. 스크립트 백그라운드를 사용하여 다음 스크립트를 실행하여 인스턴스에서 이 주제로 메시지를 게시합니다.
```
var producer = new sn_ih_kafka.ProducerV2();
producer.send('<sys id of the topic record>', gs.generateGUID(), 'Test message from ServiceNow', false, null);
```
  <주제 기록의 시스템 ID>를 주제 기록의 sys_id로 바꿔야 합니다.
2. 메시지를 보려면 1단계에서 만든 명령줄 콘솔로 이동합니다.
  메시지는 터미널 중 하나에 있어야 합니다.