プロデューサー :スコープ対象 (使用廃止)
プロデューサー API は、ServiceNow インスタンスから Kafka トピックにデータをプッシュできるようにするメソッドを提供します。
注:
この API は廃止され、 ProducerV2 - スコープ対象 API に置き換えられました。
この API には ServiceNow 統合ハブ アクションステップ - Kafka プロデューサープラグイン (com.glide.hub.action_step.kafka) が必要であり、 sn_ih_kafka 名前空間内で提供されます。
プロデューサー:send(String topic, String key, String message, Boolean isSync)
指定されたメッセージを指定された Kafka トピックに送信します。
| 名前 | タイプ | 説明 |
|---|---|---|
| トピック | 文字列 | メッセージの公開先となるトピックの名前。1 つのトピックには同じタイプのメッセージが格納されます。たとえば、Payments という名前のトピックには最近の支払いに関するメッセージが格納されると考えられます。 トピック名を入力するときは、インスタンス名のプリフィックスの後に来るものをすべて含めます。たとえば、完全なトピック名が |
| key | 文字列 | 特定のパーティションのキーの名前。トピックはパーティションに分割できます。同じキーを持つメッセージは同じパーティションに格納されます。たとえば、6 月というキーを持つ支払に関するメッセージがすべて、Payments トピックの同じパーティションに保存されます。 |
| メッセージ | 文字列 | メッセージテキスト。 |
| isSync | ブーリアン | フローがステップの完了を待ってから続行するように要求するかどうかを示すフラグ。 有効な値：
|
| タイプ | 説明 |
|---|---|
| なし |
この例では、変更されたインシデント情報を 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);