Kafka 클라이언트를 사용하여 주제의 Hermes 테스트 메시지 사용

릴리스 버전: Xanadu

업데이트 날짜 2024년 08월 01일

읽기6분

두 개의 소비자 클라이언트를 구성하여 주제의 Hermes 테스트 메시지를 사용합니다.

시작하기 전에

인스턴스가 서명된 인증서와 키 스토어를 ServiceNow® 생성하여 Kafka 주제를 보호합니다. 이용자를 Hermes 구성할 때 신뢰 저장소 및 키 저장소 상세 정보를 제공해야 합니다. 에 대한 보안 연결 설정 Hermes 메시징 서비스 문서를 참조하십시오.
를 다운로드하여 설치합니다 Apache Kafka. 클라이언트 환경 준비 Apache Kafka 문서를 참조하십시오.
메시지를 사용하기 전에 Kafka 클러스터에서 Hermes 주제를 만들고 테스트 메시지를 생성합니다. 자세한 내용은 Kafka 클라이언트를 Hermes 사용하여 테스트 주제 생성 및 Kafka 클라이언트를 사용하여 주제에 대한 Hermes 테스트 메시지 생성 문서를 참조하십시오.

필요한 역할: admin

이 태스크 정보

다음 단계에서는 두 개의 소비자 클라이언트를 구성하고 Kafka 클러스터에서 Hermes 테스트 메시지를 수신하는 방법을 설명합니다. 는 한 쌍의 Kafka 클러스터를 사용하기 때문에 Hermes 별도의 소비자 부트스트랩 주소를 사용하여 두 개의 소비자 클라이언트를 구성해야 합니다.

중요사항:

각 소비자 클라이언트에 대해 하나씩 두 개의 고유한 소비자 부트스트랩 주소를 구성해야 합니다.

비즈니스 또는 프로덕션 목적으로 메시지를 Hermes 사용할 준비가 되면 다음 단계를 참조하십시오.

프로시저

Kafka를 추출한 config 디렉터리로 이동합니다.
- 예를 들어, Unix의 경우:
```
cd /home/user/Software/kafka/config
```
- 예를 들어 Windows의 경우:
```
cd C:\Software\kafka\config
```
소비자를 구성합니다.
1. consumer.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에 대한 <경로> 를 신뢰 저장소 파일의 경로로 바꿉니다.
  - <키 저장소 암호> 를 키 저장소 암호로 바꿉니다.
  - <path to keystore.p12> 를 키 저장소 파일 경로로 바꿉니다.
3. 변경 내용을 일반 텍스트로 저장합니다.

각 소비자를 사용하여 메시지를 소비합니다.

첫 번째 소비자 클라이언트에 대해 다음 명령을 실행합니다.

유닉스:

./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --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/windows/kafka-console-consumer.bat --consumer.config config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --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

다음 자리 표시자 변수를 바꿉니다.

인스턴스 이름으로 <instance_name>
<namespace> Kafka 주제가 속한 도메인의 네임스페이스로 바꿉니다(선택 사항).
애플리케이션 ID로 <app_id>
테스트 주제 이름으로 <topic_name>
소비자가 속한 그룹에 대해 선택한 레이블이 있는 <consumer_group_id>

주:

토픽 이름의 각 부분은 대소문자를 구분합니다.

새 터미널 창을 엽니다.
Kafka 디렉터리로 이동합니다.

두 번째 소비자 클라이언트에 대해 다음 명령을 실행합니다.

유닉스:

./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --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

윈도우:

bin/windows/kafka-console-consumer.bat --consumer.config config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --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

다음 자리 표시자 변수를 바꿉니다.

인스턴스 이름으로 <instance_name>
<namespace> Kafka 주제가 속한 도메인의 네임스페이스로 바꿉니다(선택 사항).
테스트 주제 이름으로 <topic_name>
소비자가 속한 그룹에 대해 선택한 레이블이 있는 <consumer_group_id>

주:

토픽 이름의 각 부분은 대소문자를 구분합니다.

결과

테스트 메시지는 Kafka 클러스터에서 Hermes 사용됩니다.