---
sourceDocument: Yokohama データと自動化
sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/ja-JP/yokohama/integrate-applications

 Release :

    - yokohama

ft:locale :

    - ja-JP

ft:publication_title :

    - Yokohama データと自動化

ft:clusterId :

    - crint

bundleId :

    - crint

workflow :

    - Creator


---

# Kafka プロデューサーステップと ProducerV2 API を使用したメッセージの公開

# Kafka プロデューサーステップと ProducerV2 API を使用したメッセージの公開 {#ariaid-title1}

* リリースバージョン: Yokohama
* 
* 更新日 2025年01月30日
* 
* ![](https://www.servicenow.com/docs/portal-asset/ico-clock) 所要時間：4分

ServiceNow から Hermes にデータをプッシュし、Kafka コンシューマーが読み取れるようにします。

## 始める前に

* 必要なロール： integration_hub_admin
* このページは [ストリームコネクト クイックスタートガイド](https://servicenow-prod.fluidtopics.net/zZ~~4QfzQrdZE1mHsEGHQA "このクイックスタートガイドでは、ServiceNow インスタンスと Kafka 環境の間でデータを交換するために、6 つのストリームコネクトプロデューサーとコンシューマをそれぞれ設定して使用する方法の概要について説明します。")の一部です。
* このドキュメントでは、Hermes への接続を介してメッセージを公開する方法について説明します。接続の設定とテストについては、「[Hermes メッセージングサービス への安全な接続の設定](https://servicenow-prod.fluidtopics.net/Wtz6jsvqc~7S8pILnM8hPA "ServiceNow インスタンス署名証明書を生成して Kafka トピックを保護します。")」および「[ADCv2 ゲートウェイを介した Hermes への接続のテスト](https://servicenow-prod.fluidtopics.net/XLA5cKYynip6vJjNsbuQKQ "ADCv2 ゲートウェイを介して Hermes への接続をテストすることで、キーストアとトラストストアが正しく生成されていることを確認します。")」を参照してください。
* このページの前半では、ワークフロースタジオ の Kafka プロデューサーステップを使用して、Hermes にメッセージを公開する方法を説明します。ステップの詳細については、「」を参照してください。
* このページの後半では、ProducerV2 API を使用して、メッセージを公開する方法を説明します。詳細については、「ProducerV2 API」を参照してください。
* すべてのメッセージを受信するには、異なるデータセンターに対して 2 つのコンシューマーを実行する必要があります。詳細については、「[Consume test messages from a Hermes topic using the Kafka client](https://www.servicenow.com/docs/access?context=consume-messages-hermes&version=yokohama&pubname=yokohama-servicenow-platform&ft:locale=en-US)」を参照してください。
{#publish-messages-instance-hermes__ul_g1n_yg4_cyb}

## 手順

1. メッセージを受信するために、2 つのコンシューマーを起動します。
   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>` をインスタンス名で置き換えてください。
   {#publish-messages-instance-hermes__substeps_ix5_z5b_cyb}
2. フローステップを使用して、インスタンスからメッセージを公開します。
   1. 移動先 すべてプロセスの自動化フローデザイナー.
   2. 選択して新しいアクションを作成します 新規作成アクション.
   3. \[アクションプロパティ\] フォームで、アクションに名前を付けた後、\[送信\] を選択します。  
      この例では、Message Publisher という名前を使用しています。
   4. \[Kafka プロデューサー\] ステップをアクションに追加します。  
      アクションステップを追加するには、\[アクションアウトライン\] で \[入力\] と \[エラーの評価\] の間のプラス記号を選択します。  
   5. ステップで、\[トピック\] フィールドを「<kbd class="ph userinput">topic1</kbd>」に設定します。
   6. \[メッセージ\] フィールドにメッセージを入力します。  
      他のフィールドを変更する必要はありません。  
   7. \[保存\] を選択してアクションを保存します。
   8. \[テスト\] ボタンを選択してアクションをテストします。  
      アクションをテストすると、メッセージがトピックに公開されます。
   9. メッセージを表示するには、ステップ 1 で作成したコマンドラインコンソールに移動します。  
      メッセージはいずれかのターミナルに表示されているはずです。
   {#publish-messages-instance-hermes__substeps_o3b_rvb_cyb}
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);

      必ず `<sys id of the topic record>` をトピックレコードの sys_id に置き換えてください。
   2. メッセージを表示するには、ステップ 1 で作成したコマンドラインコンソールに移動します。  
      メッセージはいずれかのターミナルに表示されているはずです。
   {#publish-messages-instance-hermes__substeps_vrb_2wb_cyb}