ストリームコネクト クイックスタートガイド
このクイックスタートガイドでは、ServiceNow インスタンスと Kafka 環境の間でデータを交換するために、6 つのストリームコネクトプロデューサーとコンシューマをそれぞれ設定して使用する方法の概要について説明します。
- ワークフロースタジオ の Kafka プロデューサーステップ
- ProducerV2 API
- ワークフロースタジオ での Kafka メッセージトリガー
- 抽出変換ロード (ETL) コンシューマー
- 変換マップコンシューマー
- スクリプトコンシューマー
ServiceNow インスタンスを Kafka 環境にリンクするために、ストリームコネクトは Hermes メッセージングサービス を使用します。次の図は、プロデューサーとコンシューマーのそれぞれと、それらが Hermes を介して Kafka 環境 (ここでは 顧客サイト) に接続する方法を示しています。
詳細については、「Apache Kafka のストリームコネクトの使用」および「Hermes Messaging Service」を参照してください。
はじめに
顧客サイトを表すために、このガイドでは、コンピューターで実行される Apache Kafka コマンドラインツールを使用します。このツールで使用する設定パラメーターは、Kafka プロトコルを使用する Application Delivery Controller バージョン 2 (ADCv2) ゲートウェイへの任意のクライアント接続を構成するために使用できます。
指定されたすべてのコマンドは、OpenSSL バージョン (LibreSSL 2.8.3) および Apache Kafka バイナリディストリビューションバージョン kafka_2.13-3.4.0.tgz でテストされています。ただし、すべてのコマンドは、ローカル環境にあるどのバージョンでも機能するはずです。
クイックスタートステップ
このクイックスタートガイドには 5 つのステップがあります。ステップ 1 と 2 では、Hermes への接続を設定してテストする方法について説明します。ステップ 3 ~ 5 では、ストリームコネクトの各プロデューサーとコンシューマーを構成して使用しデータを送受信する方法を示します。
- ADCv2 ゲートウェイは相互認証を使用して要求を認証するため、最初のステップでは、お気に入りの Kafka クライアントで使用するキーストアとトラストストアを作成します。次のページでは必要な証明書を作成する方法を示しています：Set up a secure connection to the Hermes Messaging Service
- Hermes への安全な接続を設定した後、 ADCv2 ゲートウェイを介して Hermes への接続をテストすることで、キーストアとトラストストアが正しく生成されていることを確認します。
- これで、Kafka メッセージトリガーとスクリプトコンシューマーを使用してメッセージを消費する を実行できます。このページの前半では、ワークフロースタジオ で Kafka メッセージトリガーを使用して Kafka からメッセージを取得する方法を説明します。後半では、スクリプトコンシューマーを使用してメッセージを取得する方法を説明します。
- ETL および変換マップコンシューマーを使用したデータのインポート を実行します。ETL 定義と変換マップは、スケジュール済みインポートを通じてデータを取得するときに使用する変換ロジックを指定します。同じ ETL 定義と変換マップを使用して、Kafka を介して受信したイベントを変換できます。注:ETL コンシューマーを使用するには、強力なインポートセットトランスフォーマーが必要です。同様に、変換マップコンシューマーを使用するには、変換マップが必要です。
- 最後に、Kafka プロデューサーステップと ProducerV2 API を使用したメッセージの公開 を実行できます。このページでは、ワークフロースタジオ の Kafka プロデューサーステップと ProducerV2 API の両方を使用して、Kafka にメッセージをプッシュする方法について説明します。