---
sourceDocument: Yokohama データと自動化
sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/ja-JP/yokohama/integrate-applications

 Release :

    - yokohama

ft:locale :

    - ja-JP

ft:publication_title :

    - Yokohama データと自動化

ft:clusterId :

    - crint

bundleId :

    - crint

workflow :

    - Creator


---

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

# ServiceNow Kafka コンシューマー の構成 {#ariaid-title1}

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

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

## 始める前に

* 統合ハブサブスクリプションを要求します。
* [Confluent Kafka REST Proxy スポーク](https://servicenow-prod.fluidtopics.net/LFkzLXy17nPekZyp1QQbTg "Confluent Kafka REST Proxy API を介して ServiceNow インスタンスを Kafka クラスターとデータ連携します。")を有効にして設定します。
* ServiceNow Kafka コンシューマーを有効にします。
* エンティティおよびエンティティ間のマッピングを定義します。詳細については、「[強力なインポートセットトランスフォーマーのプロパティ](https://servicenow-prod.fluidtopics.net/S5xYYwkowPeE73VrERe5~w "データを抽出、変換して 1 つ以上のターゲットテーブルにロードする場合は、変換マップの代わりに強力なインポートセットトランスフォーマーを使用します。")」を参照してください。
* 必要なロール：import_admin
{#setup-kafka-consumr__ul_ll_smph_gfb}

## 手順

1. 移動先 すべてプロセスの自動化Kafka コンシューマー.
2. \[新規\] をクリックします。
3. フォームに、これらの値を入力します。  
   {#setup-kafka-consumr__table_vpc_xgd_v4b__entry__2}

   | フィールド | 説明 |
   |-|-|
   | 名前 | レコードを識別する名前です。 |
   | ブローカー接続エイリアス | [Confluent Kafka REST Proxy スポーク](https://servicenow-prod.fluidtopics.net/LFkzLXy17nPekZyp1QQbTg "Confluent Kafka REST Proxy API を介して ServiceNow インスタンスを Kafka クラスターとデータ連携します。")の接続エイリアスです。 |
   | トピック | イベントを取得するトピックです。 |
   | 強力な変換定義 | ServiceNowテーブルのイベント変換とデータストレージに使用される強力な変換定義です。詳細については、「[強力なインポートセットトランスフォーマーのプロパティ](https://servicenow-prod.fluidtopics.net/S5xYYwkowPeE73VrERe5~w "データを抽出、変換して 1 つ以上のターゲットテーブルにロードする場合は、変換マップの代わりに強力なインポートセットトランスフォーマーを使用します。")」を参照してください。 |
   | オフセット開始点 | Kafka コンシューマーの auto.offset.reset の値です。これは、初期オフセットがない場合、または現在のオフセットがサーバー上に存在しなくなった場合に、Kafka コンシューマーが行うべきことを指定します。詳細については、[Kafka2.7 ドキュメント](https://kafka.apache.org/documentation/#consumerconfigs_auto.offset.reset) を参照してください。 |
   | グループあたりのパーティション数 | コンシューマースレッドあたりのパーティション数です。 |
   | ページサイズ (バイト) | 要求の最大サイズです。 |
   | ページ制限 | 反復あたりの最大要求数です。 |
   | 埋め込み形式 | トピックの Kafka メッセージ形式です。 |
   | 要求タイムアウト (ミリ秒) | Kafka コンシューマー consumer.request.timeout.ms. の値です。これは、クライアントが要求の応答を待つ最大時間を指定したものです。詳細については、[Kafka2.7 ドキュメント](https://kafka.apache.org/documentation/#consumerconfigs_auto.offset.reset) を参照してください。 |
   | 変換エラーの発生時に停止 | 変換エラーが発生したときにリスナーを停止するオプションです。 |
   | 詳細な変換 | インポートされたすべてのイベントをインポートセットに記録し、変換のために追加のデバッグログを生成するオプションです。 |
   [ ]

   {#setup-kafka-consumr__table_vpc_xgd_v4b}  
   注:  
   トピックごとに 1 つの Kafka コンシューマーレコードを作成する必要があります。
4. \[シンクリスナーを開始\] 関連リンクをクリックします。  
   「Kafka パーティショングループリスナー状況」テーブルには、トピックのパーティションデータが入力されます。
5. **オプション:** リスナーを停止する場合は、\[シンクリスナーを開始\] 関連リンクをクリックします。
6. 移動先 システムスケジューラスケジュール済みジョブ.
7. レコード \[Kafka コンシューマートリガー\] を開きます。
8. \[トリガータイプ\] リストから、\[間隔\] を選択します。
9. \[更新\] をクリックします。