ストリームコネクト クイックスタートガイド

  • リリースバージョン: Australia
  • 更新日 2026年03月12日
  • 所要時間：26分

    • このクイックスタートガイドでは、ServiceNow インスタンスと Kafka 環境の間でデータを交換するために、6 つのストリームコネクトプロデューサーとコンシューマをそれぞれ設定して使用する方法の概要について説明します。

    ストリームコネクトには、ServiceNow から Kafka 環境にデータを送信する 2 つのプロデューサーがあります。
    • ワークフロースタジオ の Kafka プロデューサーステップ
    • ProducerV2 API
    ストリームコネクトには、Kafka 環境からデータを取得する 4 つのコンシューマーもあります。
    • ワークフロースタジオ での Kafka メッセージトリガー
    • 抽出変換ロード (ETL) コンシューマー
    • 変換マップコンシューマー
    • スクリプトコンシューマー

    ServiceNow インスタンスを Kafka 環境にリンクするために、ストリームコネクトは Hermes メッセージングサービス を使用します。次の図は、プロデューサーとコンシューマーのそれぞれと、それらが Hermes を介して Kafka 環境 (ここでは 顧客サイト) に接続する方法を示しています。

    図 : 1. ストリームコネクトのプロデューサーとコンシューマー
    ストリームコネクトのプロデューサーとコンシューマー、およびそれらが Hermes メッセージングサービスを介して Kafka 環境 (「顧客サイト」と呼ばれる) に接続する方法を示す図。

    詳細については、「Apache Kafka のストリームコネクトの使用」および「Hermes Messaging Service」を参照してください。

    はじめに

    顧客サイトを表すために、このガイドでは、コンピューターで実行される Apache Kafka コマンドラインツールを使用します。このツールで使用する設定パラメーターは、Kafka プロトコルを使用する Application Delivery Controller バージョン 2 (ADCv2) ゲートウェイへの任意のクライアント接続を構成するために使用できます。

    指定されたすべてのコマンドは、OpenSSL バージョン (LibreSSL 2.8.3) および Apache Kafka バイナリディストリビューションバージョン kafka_2.13-3.4.0.tgz でテストされています。ただし、すべてのコマンドは、ローカル環境にあるどのバージョンでも機能するはずです。

    クイックスタートステップ

    このクイックスタートガイドには 5 つのステップがあります。ステップ 1 と 2 では、Hermes への接続を設定してテストする方法について説明します。ステップ 3 ~ 5 では、ストリームコネクトの各プロデューサーとコンシューマーを構成して使用しデータを送受信する方法を示します。

    1. ADCv2 ゲートウェイは相互認証を使用して要求を認証するため、最初のステップでは、お気に入りの Kafka クライアントで使用するキーストアとトラストストアを作成します。次のページでは必要な証明書を作成する方法を示しています：Hermes メッセージングサービス への安全な接続の設定
    2. Hermes への安全な接続を設定した後、 ADCv2 ゲートウェイを介して Hermes への接続をテストすることで、キーストアとトラストストアが正しく生成されていることを確認します。
    3. これで、Kafka メッセージトリガーとスクリプトコンシューマーを使用してメッセージを消費する を実行できます。このページの前半では、ワークフロースタジオ で Kafka メッセージトリガーを使用して Kafka からメッセージを取得する方法を説明します。後半では、スクリプトコンシューマーを使用してメッセージを取得する方法を説明します。
    4. ETL および変換マップコンシューマーを使用したデータのインポート を実行します。ETL 定義と変換マップは、スケジュール済みインポートを通じてデータを取得するときに使用する変換ロジックを指定します。同じ ETL 定義と変換マップを使用して、Kafka を介して受信したイベントを変換できます。
      注:
      ETL コンシューマーを使用するには、強力なインポートセットトランスフォーマーが必要です。同様に、変換マップコンシューマーを使用するには、変換マップが必要です。
    5. 最後に、Kafka プロデューサーステップと ProducerV2 API を使用したメッセージの公開 を実行できます。このページでは、ワークフロースタジオ の Kafka プロデューサーステップと ProducerV2 API の両方を使用して、Kafka にメッセージをプッシュする方法について説明します。

    Hermes メッセージングサービス への安全な接続の設定

    ServiceNow® インスタンス署名証明書を生成して Kafka トピックを保護します。

    始める前に

    Hermes メッセージングサービス を設定するには、ネットワーク管理者および Kafka 管理者との調整が必要です。ネットワークアドミニストレーターと協力して必要なセキュリティ証明書を取得し、必要なポートを開きます。Kafka アドミニストレーターと協力して、Kafka 環境が正しく構成され、アプリケーションが標準の Kafka プロトコルを使用して Hermes メッセージングサービス に接続できることを確認します。

    次のセットアップが行われていることを確認します。

    • Hermes メッセージングサービス がアクティブ化されている。「Activating the Hermes Messaging Service」を参照してください。
    • キー管理フレームワークプラグイン (com.glide.kmf.global) がアクティブ化されている。
    • 証明書 [sys_kmf_certificate] テーブルに、ServiceNow インスタンスのルート CA 証明書が含まれている。
    • インスタンスがカスタム URL で構成されていない。カスタム URL が、インスタンス PKI 証明書ジェネレーターではサポートされていない。

    必要なロール：hermes_admin、sn_kmf.cryptographic_manager または admin

    KMF ロールのアサインの詳細については、「Roles installed with Key Management Framework」を参照してください。

    手順

    1. 移動先 すべて > 証明書ジェネレーター > インスタンス PKI 証明書ジェネレーター.
    2. オプション: 名前空間またはトピックレベルでアクセス制御リスト (ACL) を設定して、トピックへのアクセスを制御します。
      オプション説明
      名前空間に ACL を適用する
      1. [ACL を構成 (Configure ACLs)] を選択します。
      2. [トピック ACL] ダイアログボックスで、[名前空間] を選択します。
      3. 構成する名前空間を入力します。
      4. [読み取り専用] または [読み取り/書き込み] を選択して、アクセス許可レベルを設定します。
      5. [追加] を選択します。
      定義されたトピックに ACL を適用する
      1. [ACL を構成 (Configure ACLs)] を選択します。
      2. [トピック ACL] ダイアログボックスで、[定義されたトピック] を選択します。
      3. 設定する既存のトピックを入力します。
      4. [読み取り専用] または [読み取り/書き込み] を選択して、アクセス許可レベルを設定します。
      5. [追加] を選択します。
      証明書の対象者には、名前空間内のトピックまたは選択した既存のトピックへの読み取りアクセス権または読み取り/書き込みアクセス権が付与されます。
    3. Hermes メッセージングサービス のセキュリティを設定します。
      1. [インスタンス PKI 証明書ジェネレーター] ページに戻ります。
      2. [証明書パスワード] フィールドにキーストアパスワードを入力します。
      3. [生成] を選択します。
      システムは、証明書 [sys_kmf_certificate] テーブルにインスタンス署名付き証明書を生成し、キーストアを作成して、トラストストアを作成します。

      IPKI 証明書ジェネレーターで制限付き発信者アクセスが許可されていない場合は、クロススコープアクセスエラーが表示されます。制限付き発信者アクセスの許可については、 カスタマーサービス & サポート にお問い合わせください。この問題を解決するには、 カスタマーサービス & サポート Restricted Caller Access Privileges [sys_restricted_caller_access] テーブルで source_scope=76f9d51369115083f4ea77aab1677cc0 を参照できます。

    4. [キーストアをダウンロード] を選択して、キーストアのコピーを保存します。
    5. [トラストストアをダウンロード] を選択して、トラストストアのコピーを保存します。
    6. キーストアファイルとトラストストアファイルを、Hermes メッセージングサービス に接続する各プロデューサーとコンシューマークライアントにコピーします。

    タスクの結果

    これで、Hermes メッセージングサービス への安全な接続を作成できます。

    注:
    Hermes に接続するには、インスタンス PKI 証明書ジェネレーターを使用して生成したキーストアを使用する必要があります。ServiceNow のドキュメントに従って作成されていないカスタム生成のキーストアは、サポートされていません。

    ADCv2 ゲートウェイを介した Hermes への接続のテスト

    ADCv2 ゲートウェイを介して Hermes への接続をテストすることで、キーストアとトラストストアが正しく生成されていることを確認します。

    始める前に

    • 必要なロール： integration_hub_admin

    手順

    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/producer.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> はトラストストアパスワードで置き換えます。
        • <path to truststore.p12> はトラストストアファイルへのパスで置き換えます。
        • <keystore password> はキーストアパスワードで置き換えます。
        • <path to keystore.p12> はキーストアファイルへのパスで置き換えます。
      ステップ 1 ~ 3 を実行すると、Apache Kafka がダウンロードされ、producer.properties が正しく構成されるはずです。次の手順で指定するすべてのコマンドは、Apache Kafka ホームディレクトリ内で実行する必要があります。
    4. config/producer.properties ファイルを config/bootcamp.properties にコピーします。
      この例では、bootcamp を一般的な名前として使用しています。
      cp config/producer.properties config/bootcamp.properties
    5. トピックを一覧表示するには、次のコマンドを使用します。 
      bin/kafka-topics.sh --list --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003
      必ず <instance name> をインスタンス名で置き換えてください。
      インスタンスにトピックがある場合は、ここにリストされます。

    Kafka メッセージトリガーとスクリプトコンシューマーを使用してメッセージを消費する

    ワークフロースタジオ の Kafka メッセージトリガーとスクリプトコンシューマーを使用して、Hermes からメッセージを取得します。

    始める前に

    • 必要なロール： integration_hub_admin
    • このセクションの最初の部分では、 ワークフロースタジオ で Kafka メッセージトリガーを使用してメッセージを消費する方法を説明します。トリガーの詳細については、「Create a flow with a Kafka Message trigger」を参照してください。
    • このセクションの後半では、スクリプトコンシューマーを使用してメッセージを消費する方法を説明します。詳細については、「スクリプトコンシューマーの構成」を参照してください。

    手順

    1. メッセージを消費するトピックを作成します。
      1. 次のコマンドを使用して、Hermes にトピックを作成します。 
        bin/kafka-topics.sh --create --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002, <instance name>.service-now.com:4003 --topic snc.<instance name>.topic1
        必ず <instance name> をインスタンス名で置き換えてください。
      2. トピックを表示するには、インスタンスにログインし、 すべて > 統合ハブ > ストリームコネクト > トピック.
        注:
        トピックの作成には約 10 分かかります。
    2. トピックからメッセージを消費するフロートリガーを作成します。
      1. 移動先 すべて > プロセス自動化 > フローデザイナー.
      2. 選択 新規作成 > フロー.
      3. [フロープロパティ] フォームで、フローの名前を入力し、[送信] を入力します。
        この例では、Topic1 Consumer という名前を使用しています。
      4. トリガーセクションで [トリガーを追加] を選択し、トリガータイプとして [Kafka メッセージ] を選択します。
        Kafka メッセージはフローのトリガータイプです。
      5. Topic1 トピックを選択します。
        [トピック] フィールドで topic1 を選択します。

        虫眼鏡アイコンを使用すると、利用可能なトピックのリストを表示できます。

      6. フローの [アクション] セクションで、次に移動します アクション、フロー ロジック、またはサブフローを追加 > フローロジック > For Each.
      7. [メッセージ] データピルを [アイテム] フィールドにドラッグし、[完了]を選択します。
      8. フローの [アクション] セクションで、次に移動します アクション、フロー ロジック、またはサブフローを追加 > アクション > ServiceNow コア > ログ.
      9. [ペイロード] データピルを [メッセージ] フィールドにドラッグし、[完了]を選択します。
        トピック 1 コンシューマーフロートリガー。
      10. フロートリガーを [保存] します。
      11. 設定 [sys_flow_execution_setting] テーブルに移動して、このフローのレポートを有効にします。
      12. 新しいエントリを作成し、上記で作成したフローへのレポートを有効にします。
        フローのレポートを有効にするための新しい設定レコードを作成します。
      13. フローに戻り、[アクティブ化 (Activate)] を選択します。
      14. トピックのサブスクリプションを表示するには、次に移動します すべて > 統合ハブ > ストリームコネクト > サブスクリプション.
        topic1 トピックのサブスクリプション。
    3. Kafka コマンドラインツールを使用して、トピックにメッセージを公開します。
      1. 次のコマンドを実行して、topic にメッセージを公開します。 
        bin/kafka-console-producer.sh --topic snc.<instance name>.topic1  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003

        必ず <instance name> をインスタンス名で置き換えてください。

        このコマンドはメッセージの入力を促すものです。サンプルメッセージをいくつか追加します。この例では、次のメッセージを使用します。
        • テストメッセージ 1
        • テストメッセージ 2
        • テストメッセージ 3
        1 分ほどでメッセージを受信するはずです。
      2. フローに戻り、[実行]を選択します。
        [実行] を選択して、フロー実行ビューに移動します。
      3. フロー実行を開きます。
        フローの実行の詳細。
      4. このサブスクリプションの統計情報を表示するには、次に移動します すべて > 統合ハブ > ストリームコネクト > サブスクリプション、サブスクリプションを開き、統計ビューに移動します。
        サブスクリプションの Kafka 統計情報。
    4. トピックからメッセージを消費するフローコンシューマーを作成します。
      1. 移動先 統合ハブ > コンシューマー > スクリプトコンシューマー.
      2. [新規] を選択します。
      3. [名前] フィールドに、スクリプトコンシューマーの名前を入力します。
        この例では、Topic1 Consumer を使用しています。
      4. スクリプトボックスに次のロジックを追加して、メッセージをログに記録するスクリプトを設定します。 
        for (var i = 0; i < messages.length; i++) {
      gs.info('Received message ' + JSON.stringify(messages[i].message));
 }
        [イベントコンシューマー] フィールドにスクリプトを表示する Kafka スクリプトコンシューマー。
      5. フォームを保存します。
      6. [関連リンク] セクションで、[新規] を選択して、メッセージを消費する Kafka ストリームを追加します。
      7. [Kafka ストリーム] フォームで、次のフィールド値を設定します。
        • [名前] を「Topic1 Stream」を設定します。
        • [トピック] を前に作成したトピック topic1 に設定します。
        • [最大同時実行] を「1」に設定します。
        • [トピックに保存されているすべてのメッセージ (All the messages stored in the topic)] に[消費を開始 (Start Consuming)] を設定します。このオプションを使用すると、このトピックに既に公開されているメッセージを読むことができます。
        • [メッセージ処理 (Message handling)] を [自動的に最適化 (Automatically optimize)] に設定します。
        Kafka ストリームレコード。
      8. [関連リンク] の下で [アクティブ化] リンクを選択します。
        アクティブ化されたサブスクリプションを確認できるはずです。
      9. メッセージを表示するには、 すべて > システムログ > システムログ 「受信済みメッセージ」で始まるメッセージをフィルタリングします。
        受信したメッセージのリスト。
      10. 1 分後にすべてのメッセージが表示されるはずです。

    ETL および変換マップコンシューマーを使用したデータのインポート

    ETL 定義と変換マップを使用して、Kafka イベントを処理します。ETL 定義と変換マップは、スケジュール済みインポートを通じてデータを取得するときに使用する変換ロジックを指定します。同じ ETL 定義と変換マップを使用して、Kafka を介して受信したイベントを変換できます。

    始める前に

    • 必要なロール： integration_hub_admin
    • このセクションの最初の部分では、ETL コンシューマーを使用してメッセージを消費する方法を説明します。ETL コンシューマーを使用するには、強力なインポートセットトランスフォーマーが必要です。
    • このセクションの後半では、変換マップコンシューマーを使用してメッセージを消費する方法を説明します。変換マップコンシューマーを使用するには、変換マップが必要です。

    手順

    1. ETL および変換マップのコンシューマーメッセージを消費するトピックを作成します。
      1. 次のコマンドを使用して、Hermes にトピックを作成します。
        この例では、トピック名は topic2 です。 
        bin/kafka-topics.sh --create --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002, <instance name>.service-now.com:4003 --topic snc.<instance name>.topic2
        必ず <instance name> をインスタンス名で置き換えてください。
      2. トピックを表示するには、インスタンスにログインし、 すべて > 統合ハブ > ストリームコネクト > トピック.
        注:
        トピックの作成には約 10 分かかります。
    2. トピックからデータを消費する ETL コンシューマーを作成します。
      1. 移動先 すべて > 統合ハブ > コンシューマー > ETL コンシューマー.
      2. [新規] を選択します。
      3. Kafka コンシューマーフォームで、[名前] フィールドに名前を入力します。
        この例では、Member Import という名前を使用します。
      4. [強力なインポートセットトランスフォーマー] フィールドで、既存の強力なインポートセットトランスフォーマーを選択します。
        強力なインポートセットトランスフォーマーの場合は、データを単一列に格納するオプションを使用していないものを選択します。メッセージを表示できるようにするには、強力なインポートセットトランスフォーマーで [詳細 ] オプションが有効になっていることを確認してください。
      5. [単一列のデータ] オプションの選択を解除します。
        このオプションは、単一列のデータを含むインポートセットテーブルに対してのみ選択する必要があります。
      6. [列マッピング] を [ラベル] に設定します。

        これは、入力メッセージの JSON キーがインポートセットテーブルの列ラベルにマッピングされることを意味します。

        Kafka ETL コンシューマーフォーム。
      7. フォームを保存します。
      8. コンシューマー用に Kafka ストリームの作成 を行います。
      9. [Kafka ストリーム] フォームで、次のフィールド値を設定します。
        • [名前] を「Topic2 Stream」を設定します。
        • [トピック] を前に作成したトピック topic2 に設定します。
        • [最大同時実行] を「1」に設定します。
        • [消費を開始] を [最初の有効化後に受信したメッセージ (Messages received after the first activation)] に設定します。
        • [メッセージ処理 (Message handling)] を [自動的に最適化 (Automatically optimize)] に設定します。
      10. [関連リンク] の下で [アクティブ化] リンクを選択します。

        アクティブ化されたサブスクリプションを確認できるはずです。

        topic2 の Kafka ストリームフォームの例。
    3. topic2 にメッセージを公開します。
      1. 次のコマンドを実行して、topic2 にメッセージを公開します。 
        bin/kafka-console-producer.sh --topic snc.<instance name>.topic2  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003

        必ず <instance name> をインスタンス名で置き換えてください。

        このコマンドはメッセージの入力を促すものです。

      2. 次の JSON メッセージを送信します。 
        {"city":"San Diego","name":"Jhon","id":"SN001","state":"California"}
        このメッセージは任意の値で送信できますが、JSON メッセージキーはインポートセットテーブルのラベルと一致する必要があります。
      3. 作成した ETL コンシューマーに戻ります。

        約 1 分後、インポートセットを介してデータがインポートされているはずです。

        [インポートセット] タブが入力された Kafka コンシューマーフォーム。
      4. インポートセットに関する詳細情報を表示するには、インポートセット番号を選択します。
        インポートセットの詳細ビュー。
      5. インポートセット行に関する詳細情報を表示するには、インポートセット行番号を選択します。
        インポートセット行の詳細ビュー
    4. データを消費する変換マップコンシューマーを作成します。
      1. 移動先 すべて > 統合ハブ > コンシューマー > 変換マップコンシューマー.
      2. [New (新規)] を選択します。
      3. [変換マップコンシューマー] フォームで、[ 名前 ] フィールドに名前を入力します。
      4. [変換マップ] フィールドで、既存の変換マップを選択します。
        [変換マップコンシューマー] フォーム。
      5. フォームを保存します。
      6. コンシューマー用に Kafka ストリームの作成 を行います。
      7. [Kafka ストリーム] フォームで、次のフィールド値を設定します。
        • [名前] を「変換マップストリーム」に設定します。
        • [トピック] を前に作成したトピック topic2 に設定します。
        • [最大同時実行] を「1」に設定します。
        • [消費を開始] を [最初の有効化後に受信したメッセージ (Messages received after the first activation)] に設定します。
        • [メッセージ処理 (Message handling)] を [自動的に最適化 (Automatically optimize)] に設定します。
      8. [関連リンク] の下で [アクティブ化] リンクを選択します。

        アクティブ化されたサブスクリプションを確認できるはずです。

        サブスクリプション情報を含む変換マップコンシューマーの Kafka ストリームフォーム。
    5. topic2 にメッセージを公開します。
      1. 次のコマンドを実行して、topic2 にメッセージを公開します。 
        bin/kafka-console-producer.sh --topic snc.<instance name>.topic2  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003

        必ず <instance name> をインスタンス名で置き換えてください。

        このコマンドはメッセージの入力を促すものです。

      2. 次の JSON メッセージを送信します。 
        {"city":"San Diego","name":"Jhon","id":"SN001","state":"California"}
        このメッセージは任意の値で送信できますが、JSON メッセージキーはインポートセットテーブルのラベルと一致する必要があります。
      3. 作成した変換マップコンシューマーに移動します。
        約 1 分後、インポートセットを介してデータがインポートされているはずです。
      4. インポートセットに関する詳細情報を表示するには、上記ステップ 3d と同様にインポートセット番号を選択します。

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

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

    始める前に

    • 必要なロール： integration_hub_admin
    • このセクションの最初の部分では、 ワークフロースタジオ の Kafka プロデューサーステップを使用して Hermes にメッセージを公開する方法を説明します。ステップの詳細については、「Kafka Producer step」を参照してください。
    • このセクションの後半では、ProducerV2 API を使用してメッセージを公開する方法を説明します。詳細については、「ProducerV2 API」を参照してください。
    • すべてのメッセージを受信するには、異なるデータセンターに対して 2 つのコンシューマーを実行する必要があります。詳細については、「Consume test messages from a Hermes topic using the Kafka client」を参照してください。

    手順

    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> をインスタンス名で置き換えてください。
    2. フローステップを使用して、インスタンスからメッセージを公開します。
      1. 移動先 すべて > プロセス自動化 > フローデザイナー.
      2. 選択して新しいアクションを作成します 新規作成 > アクション.
      3. [アクションプロパティ] フォームで、アクションに名前を付けた後、[送信] を選択します。
        この例では、Message Publisher という名前を使用しています。
      4. [Kafka プロデューサー] ステップをアクションに追加します。

        アクションステップを追加するには、[アクションアウトライン] で [入力] と [エラーの評価] の間のプラス記号を選択します。

        Kafka プロデューサーステップをアクションに追加します。
      5. ステップで、[トピック] フィールドを「topic1」に設定します。
      6. [メッセージ] フィールドにメッセージを入力します。

        他のフィールドを変更する必要はありません。

        Kafka プロデューサーステップのフィールドに入力します。
      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);
        必ず <sys id of the topic record> をトピックレコードの sys_id に置き換えてください。
      2. メッセージを表示するには、ステップ 1 で作成したコマンドラインコンソールに移動します。
        メッセージはいずれかのターミナルに表示されているはずです。