---
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


---

# ストリームコネクト クイックスタートガイド

# ストリームコネクト クイックスタートガイド {#ariaid-title1}

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

このクイックスタートガイドでは、ServiceNow インスタンスと Kafka 環境の間でデータを交換するために、6 つのストリームコネクトプロデューサーとコンシューマをそれぞれ設定して使用する方法の概要について説明します。  
ストリームコネクトには、ServiceNow から Kafka 環境にデータを送信する 2 つのプロデューサーがあります。

* ワークフロースタジオ の Kafka プロデューサーステップ
* ProducerV2 API
{#stream-connect-quick-start__ul_znj_n3h_2yb}  
ストリームコネクトには、Kafka 環境からデータを取得する 4 つのコンシューマーもあります。

* ワークフロースタジオ での Kafka メッセージトリガー
* 抽出変換ロード (ETL) コンシューマー
* 変換マップコンシューマー
* スクリプトコンシューマー
{#stream-connect-quick-start__ul_d4k_p3h_2yb}

ServiceNow インスタンスを Kafka 環境にリンクするために、ストリームコネクトは Hermes メッセージングサービス を使用します。次の図は、プロデューサーとコンシューマーのそれぞれと、それらが Hermes を介して Kafka 環境 (ここでは 顧客サイト) に接続する方法を示しています。  
図 : 1. ストリームコネクトのプロデューサーとコンシューマー

詳細については、「[Apache Kafka のストリームコネクトの使用](https://servicenow-prod.fluidtopics.net/0sintmnk~aHXZ0V39jq4Aw "Apache Kafka 向けストリームコネクトを使用して、Apache Kafka 環境を ServiceNow インスタンスに接続します。")」および「[Hermes Messaging Service](https://www.servicenow.com/docs/access?context=hermes-messaging-service&version=yokohama&pubname=yokohama-servicenow-platform&ft:locale=en-US)」を参照してください。

## はじめに {#stream-connect-quick-start__section_vwk_y3w_xxb}

顧客サイトを表すために、このガイドでは、コンピューターで実行される Apache Kafka コマンドラインツールを使用します。このツールで使用する設定パラメーターは、Kafka プロトコルを使用する Application Delivery Controller バージョン 2 (ADCv2) ゲートウェイへの任意のクライアント接続を構成するために使用できます。

指定されたすべてのコマンドは、OpenSSL バージョン (LibreSSL 2.8.3) および Apache Kafka バイナリディストリビューションバージョン kafka_2.13-3.4.0.tgz でテストされています。ただし、すべてのコマンドは、ローカル環境にあるどのバージョンでも機能するはずです。

## クイックスタートステップ {#stream-connect-quick-start__section_oxh_dsw_xxb}

このクイックスタートガイドには 5 つのステップがあります。ステップ 1 と 2 では、Hermes への接続を設定してテストする方法について説明します。ステップ 3 \~ 5 では、ストリームコネクトの各プロデューサーとコンシューマーを構成して使用しデータを送受信する方法を示します。  
1. ADCv2 ゲートウェイは相互認証を使用して要求を認証するため、最初のステップでは、お気に入りの Kafka クライアントで使用するキーストアとトラストストアを作成します。次のページでは必要な証明書を作成する方法を示しています：[Hermes メッセージングサービス への安全な接続の設定](https://servicenow-prod.fluidtopics.net/Wtz6jsvqc~7S8pILnM8hPA "ServiceNow インスタンス署名証明書を生成して Kafka トピックを保護します。")
2. Hermes への安全な接続を設定した後、 [ADCv2 ゲートウェイを介して Hermes への接続をテストする](https://servicenow-prod.fluidtopics.net/XLA5cKYynip6vJjNsbuQKQ "ADCv2 ゲートウェイを介して Hermes への接続をテストすることで、キーストアとトラストストアが正しく生成されていることを確認します。")ことで、キーストアとトラストストアが正しく生成されていることを確認します。
3. これで、[Kafka メッセージトリガーとスクリプトコンシューマーを使用してメッセージを消費する](https://servicenow-prod.fluidtopics.net/ag1K4divgnlgRSaThOqZ8g "ワークフロースタジオ の Kafka メッセージトリガーとスクリプトコンシューマーを使用して、Hermes からメッセージを取得します。") を実行できます。このページの前半では、ワークフロースタジオ で Kafka メッセージトリガーを使用して Kafka からメッセージを取得する方法を説明します。後半では、スクリプトコンシューマーを使用してメッセージを取得する方法を説明します。
4. [ETL および変換マップコンシューマーを使用したデータのインポート](https://servicenow-prod.fluidtopics.net/vB0GRCOmj~TeVK3nZSG61A "ETL 定義と変換マップを使用して、Kafka イベントを処理します。ETL 定義と変換マップは、スケジュール済みインポートを通じてデータを取得するときに使用する変換ロジックを指定します。同じ ETL 定義と変換マップを使用して、Kafka を介して受信したイベントを変換できます。") を実行します。ETL 定義と変換マップは、スケジュール済みインポートを通じてデータを取得するときに使用する変換ロジックを指定します。同じ ETL 定義と変換マップを使用して、Kafka を介して受信したイベントを変換できます。  
   注:  
   ETL コンシューマーを使用するには、[強力なインポートセットトランスフォーマー](https://servicenow-prod.fluidtopics.net/S5xYYwkowPeE73VrERe5~w "データを抽出、変換して 1 つ以上のターゲットテーブルにロードする場合は、変換マップの代わりに強力なインポートセットトランスフォーマーを使用します。")が必要です。同様に、変換マップコンシューマーを使用するには、[変換マップ](https://servicenow-prod.fluidtopics.net/RPXxiBEruFYNmW1p2od7Yw "変換マップは、インポートセットのフィールドと、インシデント [incident] やユーザー [sys_user] などの既存の ServiceNow テーブルのフィールドとの関係を決定するフィールドマップのセットです。")が必要です。
5. 最後に、[Kafka プロデューサーステップと ProducerV2 API を使用したメッセージの公開](https://servicenow-prod.fluidtopics.net/RE4B67ciMC_MnKJuIPpwSg "ServiceNow から Hermes にデータをプッシュし、Kafka コンシューマーが読み取れるようにします。") を実行できます。このページでは、ワークフロースタジオ の Kafka プロデューサーステップと ProducerV2 API の両方を使用して、Kafka にメッセージをプッシュする方法について説明します。
{#stream-connect-quick-start__ol_z2t_2kw_xxb}