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

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

시작하기 전에

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

필요한 역할: 관리자

이 태스크 정보

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

중요사항:

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

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

프로시저

1. Kafka를 추출한 구성 디렉터리로 이동합니다.
   • 예를 들어, Unix의 경우:

     cd /home/user/Software/kafka/config

   • 예를 들어 Windows의 경우:

     cd C:\Software\kafka\config

2. 소비자를 구성합니다.
   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 경로> 신뢰 저장소 파일의 경로
      • <키 저장소 암호> 키를 키 저장소 암호 포함
      • <keystore.p12 경로> 키 스토어 파일의 경로
   3. 변경 내용을 일반 텍스트로 저장합니다.
3. 각 소비자를 사용하여 메시지를 소비합니다.
   1. 첫 번째 소비자 클라이언트에 대해 다음 명령을 실행합니다.
      유닉스:

      ./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

      Windows:

      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>
      • <네임스페이스> : Kafka 주제가 속한 도메인의 네임스페이스를 사용합니다(선택 사항).
      • 애플리케이션 ID로 <app_id>
      • 테스트 주제 이름이 있는 <topic_name>
      • 소비자가 속한 그룹에 대해 선택한 레이블이 있는 <consumer_group_id>

      주:

      주제 이름의 각 부분은 대/소문자를 구분합니다.
   2. 새 터미널 창을 엽니다.
   3. Kafka 디렉터리로 이동합니다.
   4. 두 번째 소비자 클라이언트에 대해 다음 명령을 실행합니다.
      유닉스:

      ./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

      Windows:

      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>
      • <네임스페이스> : Kafka 주제가 속한 도메인의 네임스페이스를 사용합니다(선택 사항).
      • 테스트 주제 이름이 있는 <topic_name>
      • 소비자가 속한 그룹에 대해 선택한 레이블이 있는 <consumer_group_id>

      주:

      주제 이름의 각 부분은 대/소문자를 구분합니다.

결과

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