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

  • リリースバージョン: Australia
  • 更新日 2026年03月12日
  • 所要時間：2分

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

    始める前に

    手順

    1. 移動先 すべて > プロセス自動化 > Kafka コンシューマー.
    2. [New] をクリックします。
    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. [更新] をクリックします。