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

  • リリースバージョン: Xanadu
  • 更新日 2024年08月01日
  • 所要時間：4分

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

    始める前に

    手順

    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. 移動先 すべて > プロセスの自動化 > Flow Designer.
      2. を選択して新しいアクションを作成します 新規作成 > [Action (アクション)].
      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 で作成したコマンドラインコンソールに移動します。
        メッセージはいずれかのターミナルに表示されているはずです。