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

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

시작하기 전에

• 필요한 역할: integration_hub_admin
• 이 페이지는 스트리밍 연결 퀵 스타트 가이드의 일부입니다.
• 이 문서에서는 Hermes에 대한 연결을 통해 메시지를 게시하는 방법을 보여줍니다. 연결을 설정하고 테스트하려면 ADCv2 게이트웨이를 통한 Hermes 연결 테스트를 참조하세요Set up a secure connection to the Hermes Messaging Service.
• 이 페이지의 첫 번째 부분에서는 Kafka Producer 단계를 워크플로우 스튜디오 사용하여 Hermes에 메시지를 게시하는 방법을 보여줍니다. 단계에 대한 자세한 내용은 다음 문서를 참조하십시오 Kafka Producer step.
• 이 페이지의 두 번째 부분에서는 ProducerV2 API를 사용하여 메시지를 게시하는 방법을 보여 줍니다. 자세한 내용은 ProducerV2 API를 참조하세요.
• 모든 메시지를 받으려면 서로 다른 데이터센터에 대해 두 개의 소비자를 실행해야 합니다. 자세한 내용은 Consume test messages from a Hermes topic using the Kafka client 문서를 참조하십시오.

프로시저

1. 메시지를 수신할 두 명의 소비자를 시작합니다.
   1. 명령줄에서 다음 명령을 실행하여 메시지를 수신합니다.

      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

      <instance name>을 인스턴스의 이름으로 바꿔야 합니다.
2. 플로우 단계를 사용하여 인스턴스에서 메시지를 게시합니다.
   1. 다음으로 이동 모두 > 프로세스 자동화 > 플로우 디자이너.
   2. 을 선택하여 새 작업 생성 새로 생성 > 작업.
   3. 작업 속성 양식에서 작업에 이름을 지정한 다음, 제출을 선택합니다.
      이 예에서는 Message Publisher라는 이름을 사용합니다.
   4. 작업에 Kafka 생산 자 단계를 추가합니다.

      동작 단계를 추가하려면 동작 개요에서 입력 과 오류 평가 사이에 있는 더하기 기호를 선택합니다.

      

   5. 이 단계에서 주제 필드를 topic1로 설정합니다.
   6. 메시지 필드에 메시지를 입력합니다.

      다른 필드는 변경할 필요가 없습니다.

      

   7. 저장을 선택하여 작업을 저장합니다.
   8. 테스트 단추를 선택하여 작업을 테스트합니다.
      작업을 테스트하면 주제에 메시지가 게시됩니다.
   9. 메시지를 보려면 1단계에서 만든 명령줄 콘솔로 이동합니다.
      메시지는 터미널 중 하나에 있어야 합니다.
3. 스크립트를 사용하여 인스턴스에서 메시지를 게시합니다.
   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단계에서 만든 명령줄 콘솔로 이동합니다.
      메시지는 터미널 중 하나에 있어야 합니다.