---
sourceDocument: オーストラリア API リファレンス
sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/ja-JP/api-reference

 Release :

    - australia

ft:locale :

    - ja-JP

ft:publication_title :

    - オーストラリア API リファレンス

ft:clusterId :

    - crapiref

bundleId :

    - crapiref

workflow :

    - Creator


---

# ProducerV2 - スコープ対象

# ProducerV2 - スコープ対象 {#ariaid-title1}

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

ProducerV2 API は、ServiceNow インスタンスから Kafka トピックにメッセージを公開するメソッドを提供します。  
注:  
この API には ストリームコネクト サブスクリプションが必要です。詳細については、「<https://www.servicenow.com/now-platform/workflow-data-fabric.html>」を参照してください。
この API は ServiceNow ストリームコネクトインストーラープラグイン (com.glide.hub.stream_connect.installer) を必要とし、 `sn_ih_kafka` 名前空間で実行されます。

## ProducerV2 - send(文字列 topicSysID, 文字列キー, 文字列メッセージ, ブール isSync, オブジェクトヘッダー, 文字列 schemaID) {#ariaid-title2}

指定されたメッセージを指定された Kafka トピックに送信します。
{#ProducerV2-send-S_S_S_B_O__table_vn5_c3f_nvb__entry__3}

| 名前 | タイプ | 説明 |
|-|-|-|
| トピック SysID | 文字列 | メッセージの公開先トピックのSys_id。トピックは Kafka トピック \[sys_kafka_topic\] テーブルに格納されます。 |
| key | 文字列 | トピック内の特定のパーティションのキーの名前。 |
| メッセージ | 文字列 | メッセージテキスト。 |
| isSync | ブーリアン | 続行する前にスクリプトが send メソッドの完了を待つように要求するかどうかを示すフラグ。 有効な値： * true:ステップが完了するのを待ってから、関連するフローを続行します。 * false:ステップが完了するのを待たずに、関連するフローを続行します。 |
| ヘッダー | オブジェクト | キーと値のペアとして定義されたメッセージのヘッダー。 "headers": { "<key>": "<value>" } たとえば、 `var headers = { "origin": "sn_business_rule" };` * `key`:文字列。ヘッダーの名前。 * `値`:文字列。ヘッダーの値。 |
| スキーマ ID | 文字列 | スキーマレコードのSys_id。 スキーマを使用してプレーンテキストメッセージを Avro メッセージに変換したり、その逆を行ったりする場合は必須です。スキーマは、ストリームコネクトスキーマ \[stream_connect_schema\] テーブルに保存されます。詳細については、「[Schema management in Stream Connect](https://www.servicenow.com/docs/access?context=schema-management&version=australia&pubname=australia-integrate-applications&ft:locale=en-US)」を参照してください。 |
[表 : 1. パラメーター]

{#ProducerV2-send-S_S_S_B_O__table_vn5_c3f_nvb} {#ProducerV2-send-S_S_S_B_O__table_wn5_c3f_nvb__entry__2}

| オブジェクトのプロパティ | 説明 |
|-|-|
| 配達 | Kafka プロデューサーの配信。isSyncパラメーターに設定された値を反映します。 可能な値： * async - 非同期配信 * sync:同期配信 {#ProducerV2-send-S_S_S_B_O__ul_b1n_khp_bgc} データタイプ：文字列 |
| オフセット | Hermes Kafka のトピックのパーティション内のメッセージのオフセット。この値は、同期配信の場合にのみ返されます。 データタイプ：数値 |
| パーティション | メッセージが保存されるトピックのパーティション。この値は、同期配信の場合にのみ返されます。 データタイプ：数値 |
[表 : 2. 戻り値]

{#ProducerV2-send-S_S_S_B_O__table_wn5_c3f_nvb}  

### 非同期配信 {#ProducerV2-send-S_S_S_B_O__example_q5d_bhp_bgc}

この例では、sys_id f9d083f3ff610210ef7343d3653bf12e のスキーマを使用して、sys_id 75135aa2ff0311105cf343d0653bf155 で変更されたインシデント情報を Kafka トピックに送信する方法を示します。

    var message = {
      'number': current.number.toString(),
      'short_description': current.short_description.toString(),
      'caller_id': current.caller_id.getDisplayValue(),
      'priority': current.priority.toString(),
      'state': current.state.toString()
    };

    var headers = {
        'origin': 'sn_business_rule'
    };

    var producer = new sn_ih_kafka.ProducerV2();
    producer.send('75135aa2ff0311105cf343d0653bf155', gs.generateGUID(), JSON.stringify(message), false, headers, 'f9d083f3ff610210ef7343d3653bf12e');

### 同期配信

この例では、Kafka メッセージの戻り値を取得する方法を示します。

    var message = "Defect fix";
     
    var producer = new sn_ih_kafka.ProducerV2();
     
    var response = producer.send('63820c0e1b492210dcff64e5604bcb93', gs.generateGUID(), JSON.stringify(message), true, null);
    gs.log("Partition was "+response.partition);
    gs.log("Offset was :"+response.offset);
    gs.log("Delivery was :"+response.delivery);

出力:

    *** Script: Partition was 1
    *** Script: Offset was :258072
    *** Script: Delivery was :sync