---
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


---

# プロデューサー :スコープ対象 (使用廃止)

# プロデューサー :スコープ対象 (使用廃止) {#ariaid-title1}

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

プロデューサー API は、ServiceNow インスタンスから Kafka トピックにデータをプッシュできるようにするメソッドを提供します。  
注:  
この API は廃止され、 [ProducerV2 - スコープ対象](https://servicenow-prod.fluidtopics.net/MBZxOp37IEUSe~Bzki47Ig#ProducerV2ScopedAPI "ProducerV2 API は、ServiceNow インスタンスから Kafka トピックにメッセージを公開するメソッドを提供します。") API に置き換えられました。

この API には ServiceNow 統合ハブ アクションステップ - Kafka プロデューサープラグイン (com.glide.hub.action_step.kafka) が必要であり、 `sn_ih_kafka` 名前空間内で提供されます。

## プロデューサー:send(String topic, String key, String message, Boolean isSync) {#ariaid-title2}

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

| 名前 | タイプ | 説明 |
|-|-|-|
| トピック | 文字列 | メッセージの公開先となるトピックの名前。1 つのトピックには同じタイプのメッセージが格納されます。たとえば、Payments という名前のトピックには最近の支払いに関するメッセージが格納されると考えられます。 トピック名を入力するときは、インスタンス名のプリフィックスの後に来るものをすべて含めます。たとえば、完全なトピック名が `snc.<instancename>.sn_streamconnect.<topicname>` の場合、\[トピック\] フィールドに「 `sn_streamconnect.<topicname>` 」と入力します。 |
| key | 文字列 | 特定のパーティションのキーの名前。トピックはパーティションに分割できます。同じキーを持つメッセージは同じパーティションに格納されます。たとえば、6 月というキーを持つ支払に関するメッセージがすべて、Payments トピックの同じパーティションに保存されます。 |
| メッセージ | 文字列 | メッセージテキスト。 |
| isSync | ブーリアン | フローがステップの完了を待ってから続行するように要求するかどうかを示すフラグ。 有効な値： * true:ステップが完了するのを待ってから、関連するフローを続行します。 * false:ステップが完了するのを待たずに、関連するフローを続行します。 |
[表 : 1. パラメーター]

{#Producer-send-S_S_S_B__table_scd_fzf_mrb} {#Producer-send-S_S_S_B__table_tcd_fzf_mrb__entry__2}

| タイプ | 説明 |
|-|-|
| なし |   |
[表 : 2. 返される内容]

{#Producer-send-S_S_S_B__table_tcd_fzf_mrb}  
この例では、変更されたインシデント情報を changed_incidents 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 producer = new sn_ih_kafka.Producer();
    producer.send('changed_incidents', current.number.toString(), JSON.stringify(message), false);


