Kafka 環境からデータをインポートし、既存の強力な変換エンジン (RTE) 構成を使用してそのデータを処理します。

始める前に

• 必要なロール： integration_hub_admin
• このコンシューマは Apache Kafka 向けストリームコネクト の一部で、Apache Kafka 向けストリームコネクト サブスクリプションが必要です。詳細については、「https://www.servicenow.com/products/automation-engine.html」を参照してください。
• 以下のプラグインが必要です。
  • ServiceNow IntegrationHub Kafka Consumer (com.glide.hub.kafka_consumer) プラグイン。
  • ServiceNow IntegrationHub ETL Consumer - Kafka (com.glide.hub.etl_consumer.kafka) プラグイン。
• このコンシューマーには、強力なインポートセットトランスフォーマーが必要です。

このタスクについて

手順

1. 移動先 すべて > 統合ハブ > コンシューマー > ETL コンシューマー.
2. [新規] を選択します。
3. フォームのフィールドに入力します。

   表 : 1. Kafka ETL コンシューマー

   フィールド	説明
   名前	ETL コンシューマーの名前。
   強力なインポートセットトランスフォーマー	データの処理に使用する強力なインポートセットトランスフォーマーの名前。
   配送保証	ノード障害が発生した場合に、受信メッセージの配信保証を指定するオプション。次のいずれかを選択します。 [紛失なし重複あり (No lost but duplicates)]：すべてのメッセージが少なくとも 1 回配信されるようにします。一部のメッセージは複数回配信される可能性があります。 [1 回またはなし (Once or not at all)]：メッセージが複数回配信されないようにします。一部のメッセージがまったく配信されない可能性があります。
   単一列のデータ	単一列にインポートセットテーブルを格納させるオプション。
   列マッピング	メッセージの JSON キーがデータをインポートセットテーブルの列の名前またはラベルにマッピングするかどうかを指定するオプション。次のいずれかを選択します。 ラベル 列名 このフィールドは、[単一列のデータ] チェックボックスがオフの場合にのみ表示されます。
   アプリケーション	ETL コンシューマーのアプリケーションスコープ。

4. [保存] を選択します。

次のタスク

このコンシューマーの Kafka ストリームの作成。ストリームがアクティブ化されると、Kafka 環境からのメッセージの受信を開始できます。