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

  • 릴리스 버전: Xanadu
  • 업데이트 날짜 2024년 08월 01일
  • 읽기6분

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

    시작하기 전에

    필요한 역할: admin

    이 태스크 정보

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

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

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

    프로시저

    1. Kafka를 추출한 config 디렉터리로 이동합니다.
      • 예를 들어, 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에 대한 <경로> 를 신뢰 저장소 파일의 경로로 바꿉니다.
        • <키 저장소 암호> 를 키 저장소 암호로 바꿉니다.
        • <path to 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
        윈도우:
        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. 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
        윈도우:
        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 사용됩니다.