ServiceNow Kafka コンシューマー

  • リリースバージョン: Washingtondc
  • 更新日 2024年02月01日
  • 読む4読むのに数分
  • ServiceNowインスタンスを Kafka コンシューマーとデータ連携し、データをServiceNowテーブルに保存します。

    ストアでアプリを要求する

    ServiceNow Store Web サイトにアクセスして利用可能なすべてのアプリを表示し、ストアにリクエストを送信する方法について確認してください。リリースされたすべてのアプリのリリースノート情報については、「ServiceNow Storeバージョン履歴のリリースノート」を参照してください。

    統合ハブサブスクリプション

    このスポークには Integration Hub のサブスクリプションが必要です。詳細については、「法務スケジュール - IntegrationHub の概要」を参照してください。

    サポートされているバージョン

    このスポークは、Confluent REST プロキシ API v2 用に構築されています。

    スポークの依存関係

    アプリのインストールで問題が発生した場合は、次の依存プラグインがインストールされていることを確認してください。
    • Confluent Kafka REST Proxy スポーク
    • ServiceNow IntegrationHub Runtime (com.glide.hub.integration.runtime)
    • ServiceNow IntegrationHub アクションステップ - RTE (com.glide.hub.action_step.rte)
    注:
    これらのプラグインの一部はライセンス可能な機能であり、スポーク実装の外部で使用する場合は適切なライセンスが必要です。

    接続および資格情報エイリアスの要件

    統合ハブ は、エイリアスを使用して、接続および資格情報を管理します。エイリアスを使用することで、複数の環境を使用する場合に、複数の資格情報と接続情報プロファイルを構成する必要がなくなります。接続または資格情報が変更された場合、接続を使用するどのアクションも更新する必要はありません。詳細については、「Connections and Credentials」を参照してください。

    ServiceNowKafka コンシューマーは、Confluent Kafka REST Proxy スポークの接続および資格情報エイリアスを使用します。

    ServiceNow Kafka コンシューマー の構成

    指定されたトピックに関連するイベントを取得し、必要なServiceNow テーブルに保存します。

    始める前に

    手順

    1. 移動先 すべて > プロセス自動化 > Kafka コンシューマー.
    2. [新規] をクリックします。
    3. フォームに、これらの値を入力します。
      フィールド 説明
      名前 レコードを識別する名前です。
      ブローカー接続エイリアス Confluent Kafka REST Proxy スポークの接続エイリアスです。
      トピック イベントを取得するトピックです。
      強力な変換定義 ServiceNowテーブルのイベント変換とデータストレージに使用される強力な変換定義です。詳細については、「強力なインポートセットトランスフォーマーのプロパティ」を参照してください。
      オフセット開始点 Kafka コンシューマーの auto.offset.reset の値です。これは、初期オフセットがない場合、または現在のオフセットがサーバー上に存在しなくなった場合に、Kafka コンシューマーが行うべきことを指定します。詳細については、Kafka2.7 ドキュメント を参照してください。
      グループあたりのパーティション数 コンシューマースレッドあたりのパーティション数です。
      ページサイズ (バイト) 要求の最大サイズです。
      ページ制限 反復あたりの最大要求数です。
      埋め込み形式 トピックの Kafka メッセージ形式です。
      要求タイムアウト (ミリ秒) Kafka コンシューマー consumer.request.timeout.ms. の値です。これは、クライアントが要求の応答を待つ最大時間を指定したものです。詳細については、Kafka2.7 ドキュメント を参照してください。
      変換エラーの発生時に停止 変換エラーが発生したときにリスナーを停止するオプションです。
      詳細な変換 インポートされたすべてのイベントをインポートセットに記録し、変換のために追加のデバッグログを生成するオプションです。
      注:
      トピックごとに 1 つの Kafka コンシューマーレコードを作成する必要があります。
    4. [シンクリスナーを開始] 関連リンクをクリックします。
      「Kafka パーティショングループリスナーステータス」テーブルには、トピックのパーティションデータが入力されます。
    5. オプション: リスナーを停止する場合は、[シンクリスナーを開始] 関連リンクをクリックします。
    6. 移動先 システムスケジューラ > ジョブスケジュール.
    7. レコード [Kafka コンシューマートリガー] を開きます。
    8. [トリガータイプ] リストから、[間隔] を選択します。
    9. [更新] をクリックします。