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

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

시작하기 전에

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

필요한 역할: admin

이 태스크 정보

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

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

프로시저

1. 를 다운로드하여 설치합니다 Apache Kafka.
   1. 다운로드 Apache Kafka 바이너리.
   2. 다음 명령을 실행하여 Kafka 패키지의 압축을 풉니다.

      tar -zxvf kafka_2.13-3.1.2.tgz

2. 다음 명령을 실행하여 Kafka 디렉터리로 이동합니다.

   cd kafka_2.13-3.1.2

3. 소비자를 구성합니다.
   1. config/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 password> 를 truststore 비밀번호로 바꿉니다.
      • truststore.p12에 대한 <경로> 신뢰 저장소 파일의 경로로 바꿉니다.
      • <keystore password> 를 keystore 암호로 바꿉니다.
      • <path to keystore.p12> 키 저장소 파일의 경로로 바꿉니다.
4. 각 소비자를 사용하여 메시지를 사용합니다.
   1. 첫 번째 소비자 클라이언트에 대해 다음 명령을 실행합니다.
      Unix:

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

      주:

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

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

      주:

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

결과

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

관련 태스크

• Kafka 클라이언트를 Hermes 사용하여 테스트 주제 생성
• Kafka 클라이언트를 Hermes 사용하여 주제에 대한 테스트 메시지 생성