---
sourceDocument: Xanadu API リファレンス
sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/ja-JP/xanadu/api-reference

 Release :

    - xanadu

ft:locale :

    - ja-JP

ft:publication_title :

    - Xanadu API リファレンス

ft:clusterId :

    - crapiref

bundleId :

    - crapiref

workflow :

    - Creator


---

# プロデューサー :スコープ指定 (非推奨)

# プロデューサー :スコープ指定 (非推奨) {#ariaid-title1}

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

Producer API は、ServiceNow インスタンスから Kafka トピックにデータをプッシュ可能にするメソッドを提供します。  
注:  
この API は廃止され、 [ProducerV2 - スコープ指定](https://servicenow-prod.fluidtopics.net/sPVWKQg9VjSeHVQiuZol0A#ProducerV2ScopedAPI "ProducerV2 API は、ServiceNowインスタンスから Kafka トピックにメッセージを公開するためのメソッドを提供します。") API に置き換えられました。

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

## Producer - send(文字列 topic, 文字列 key, 文字列 message, ブーリアン isSync) {#ariaid-title2}

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

| 名前 | タイプ | 説明 |
|-|-|-|
| topic | 文字列 | メッセージの公開先となるトピックの名前。1 つのトピックには同じタイプのメッセージが格納されます。たとえば、Payments という名前のトピックには最近の支払いに関するメッセージが格納されると考えられます。 トピック名を入力するときは、インスタンス名のプリフィックスの後にあるものをすべて含めます。たとえば、完全なトピック名が `snc.<instancename>.sn_streamconnect.<topicname>` の場合は、トピックフィールドに `「sn_streamconnect.<topicname>` 」と入力します。 |
| key | 文字列 | 特定のパーティションのキーの名前。トピックはパーティションに分割できます。同じキーを持つメッセージは同じパーティションに格納されます。たとえば、6 月というキーを持つ支払に関するメッセージがすべて、Payments トピックの同じパーティションに保存されます。 |
| message | 文字列 | メッセージのテキスト。 |
| 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);


