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


---

# ストリームコネクトでメッセージと Kafka トピックレプリケーションを作成する

# ストリームコネクトでメッセージと Kafka トピックレプリケーションを作成する {#ariaid-title1}

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

メッセージとトピックレプリケーションをセットアップして、Apache Kafka 環境と ServiceNow の間でデータを複製します。

## 始める前に

* 必要なロール：message_replication_admin
* この機能には サブスクリプションが必要です。詳細については、「[Apache Kafka のストリームコネクトの使用](https://servicenow-prod.fluidtopics.net/0sintmnk~aHXZ0V39jq4Aw "Apache Kafka 向けストリームコネクトを使用して、Apache Kafka 環境を ServiceNow インスタンスに接続します。")」を参照してください。
* Hermes メッセージングサービスとインスタンス PKI 証明書ジェネレーターが機能していることを確認します。
  * [Check the status of and connection to the Hermes Kafka cluster](https://www.servicenow.com/docs/access?context=run-hermes-messaging-service-diagnostics&version=yokohama&pubname=yokohama-servicenow-platform&ft:locale=en-US)に展開したカスタムモバイルアプリケーションを使用して管理しました。
  * [Key Management Framework Health](https://www.servicenow.com/docs/access?context=kmf_diagnostics&version=yokohama&pubname=yokohama-platform-security&ft:locale=en-US)をチェックして、インスタンス PKI セクションの 3 つの項目すべてが動作していることを確認します。
  {#configure-message-topic-reps-sc__ul_hyn_jkx_qzb}
* MID サーバーを構成して開始します。詳細については、「[Configuring MID Servers](https://www.servicenow.com/docs/access?context=c_MIDServerConfiguration&version=yokohama&pubname=yokohama-servicenow-platform&ft:locale=en-US)」を参照してください。MID サーバーは、ファイアウォールを介して Hermes エンドポイントにアクセスできなければなりません。ネットワークアドミニストレーターと協力して、次のポート範囲が開いていることを確認します。
  * プロデューサー： 4000 ～ 4050
  * コンシューマー 1：4100 ～ 4150
  * コンシューマー 2：4200 ～ 4250
  {#configure-message-topic-reps-sc__ul_lzv_pj5_pzb}
* ストリームコネクトメッセージレプリケーションは、接続および資格情報エイリアスを使用してローカル Kafka に接続します。\[接続タイプ\] が \[Kafka\] の[Create a Connection \& Credential alias](https://www.servicenow.com/docs/access?context=connection-alias&version=yokohama&pubname=yokohama-platform-security&ft:locale=en-US)。接続および資格情報エイリアスには、 [\[Kafka 接続 (Kafka Connection)\]](Tot54B_cR2rIf2ZMwIQOpQ "Apache Kafka 環境への接続を構成します。") と [\[Kafka SSL 認証情報\]](F22XPRzBpELmpSzy8q5oKA "Apache Kafka 接続の SSL 認証情報を構成します。")が必要です。
* ストリームコネクトメッセージレプリケーションには、ServiceNow Stream Connect Installer \[com.glide.hub.stream_connect.installer\] プラグインが必要です。
{#configure-message-topic-reps-sc__ul_z2v_3mr_hzb}

## このタスクについて

このページでは、メッセージレプリケーションレコードと関連する Kafka トピックレプリケーションレコードを作成する方法について説明します。

メッセージレプリケーションレコードは、単一の Kafka クラスターを表します。たとえば、2 つの Kafka クラスターがある場合は、クラスターごとに 1 つずつ、合計 2 つの異なるメッセージレプリケーションレコードを作成します。メッセージレプリケーションレコードは、そのクラスターとの間で複製されるすべてのトピックの親レコードです。メッセージレプリケーションレコードは、メッセージレプリケーション \[sys_sc_message_replication\] テーブルに格納されます。

Kafka トピックレプリケーションレコードは、単一のソーストピックから単一の宛先トピックへのレプリケーションを指定します。単一のソーストピックを複数の宛先に複製することはできません。各宛先への複製は 1 回のみ可能です。Kafka トピックレプリケーションレコードは、Kafka トピックレプリケーション \[sys_kafka_topic_replication\] テーブルに格納されます。

## 手順

1. 移動先 すべて統合ハブストリームコネクトメッセージレプリケーション をクリックし、\[ 新規\] を選択します。
2. \[メッセージレプリケーション\] フォームで、フィールドに入力します。  
   {#configure-message-topic-reps-sc__table_icx_wyc_hzb__entry__2}

   | フィールド | 説明 |
   |-|-|
   | 名前 | メッセージレプリケーションの名前。 |
   | メッセージングサービス接続 (Messaging service connection) | 接続先のメッセージングサービスを指定する接続および資格情報エイリアス。 |
   | ステータス | メッセージレプリケーションの前回の既知のステータス。このフィールドは自動的に設定されます。 |
   | エラーメッセージ | メッセージレプリケーションの前回の既知のステータスに基づいたエラーメッセージ。このフィールドは自動的に設定されます。 |
   | アプリケーション | メッセージレプリケーションのアプリケーションスコープ。このフィールドは自動的に設定されます。 |
   | アクティブ | メッセージのレプリケーションをアクティブ化するオプション。 |
   [表 : 1. メッセージレプリケーションフォーム]

   {#configure-message-topic-reps-sc__table_icx_wyc_hzb}
3. \[保存\] を選択します。  
   フォームを保存すると、\[Kafka トピックレプリケーション (Kafka Topic Replications)\] タブがページの下部に表示されます。
4. \[Kafka トピックレプリケーション (Kafka Topic Replications)\] タブで、\[新規\] を選択します。
5. \[Kafka トピックレプリケーション (Kafka Topic Replications)\] フォームで、フィールドに入力します。  
   {#configure-message-topic-reps-sc__table_smq_zzc_hzb__entry__2}

   | フィールド | 説明 |
   |-|-|
   | 名前 | トピックレプリケーションの名前。名前は、他のフィールドの値に基づいて自動的に生成されます。 \[名前\]を生成するには、\[方向\]、\[ServiceNow トピック (ServiceNow topic)\]、および \[トピック名\] フィールドに値を入力し、\[保存\] を選択します。 \[方向\] が \[ServiceNow へ (To ServiceNow)\] の場合、名前の形式は、`トピック名 [レプリケーション名] -> `ServiceNow` トピック名 [SN]` になります。 \[方向\] が \[ServiceNow から (From ServiceNow)\] の場合、名前の形式は、ServiceNow`トピック名 [SN] -> トピック名 [レプリケーション名]` になります。 |
   | 方向 | トピックのレプリケーションの方向。 * \[ServiceNow へ (To ServiceNow)\] は、ローカルの Kafka 環境から ServiceNow にトピックをレプリケートします。 * \[ServiceNow から (From ServiceNow)\] は、ServiceNow からローカルの Kafka 環境にトピックをレプリケートします。 {#configure-message-topic-reps-sc__ul_rdp_hbg_pzb} |
   | ServiceNow トピック | Kafka トピック \[sys_kafka_topic\] テーブルへの参照。 |
   | レプリケーション | このトピックのレプリケーションを管理するメッセージレプリケーション。 |
   | トピック名 | ローカル Kafka 環境内のトピックの名前。 |
   | アクティブ | トピックのレプリケーションをアクティブ化するオプション。 |
   | ステータス | トピックレプリケーションの前回の既知のステータス。このフィールドは自動的に設定されます。 |
   | エラーメッセージ | トピックレプリケーションの前回の既知のステータスに基づいたエラーメッセージ。このフィールドは自動的に設定されます。 |
   | 現在の更新セット内で追跡 (Track in current update set) | 選択すると、トピックレプリケーションが現在の更新セットに追加されるため、準本番インスタンスから本番インスタンスに簡単に昇格できます。このフィールドを追加するためにフォームを構成しなければならない場合があります。 |
   [表 : 2. Kafka トピックレプリケーションフォーム]

   {#configure-message-topic-reps-sc__table_smq_zzc_hzb}
6. \[送信\] を選択します。
7. ステップ 1 〜 6 に従って、すべての Kafka クラスターとトピックのメッセージとトピックレプリケーションを作成します。

## タスクの結果

すべてのメッセージとトピックのレプリケーションレコードを作成したら、メッセージをレプリケートする必要があります。メッセージのレプリケーションレコードの \[ステータス\] フィールドと \[エラーメッセージ\] フィールドで、レプリケーションの動作に関する一般的なステータスを確認できます。

個々の Kafka トピックレプリケーションレコードの \[ステータス\] フィールドと \[エラーメッセージ\] フィールドで、特定のトピックのレプリケーションのステータスを確認することもできます。

各 Kafka トピックレプリケーションレコードには、\[メッセージレプリケーション統計情報 (Message Replication Statistics)\] という名前の関連リストもあります。レプリケーションが実行されると、このリストには、各トピックのレプリケーションに対して 60 秒ごとに作成されるメトリクスレコードが表示されます。各メトリクスレコードには、それぞれの収集間隔で複製されたメッセージの数を示す \[メッセージ数\] など、トピックレプリケーションに関する情報が含まれています。

## 次のタスク

ローカルの Kafka から ServiceNow にメッセージをレプリケートする場合は、[スクリプト](https://servicenow-prod.fluidtopics.net/VPJ2dGbA2xt~6YeEFMXHxA "スクリプトを使用して、Kafka 環境からデータをインポートして処理します。")、[ETL](https://servicenow-prod.fluidtopics.net/dZ5b~GXAAN8ySCpAwoq2gQ "Kafka 環境からデータをインポートし、既存の強力な変換エンジン (RTE) 構成を使用してそのデータを処理します。")、または[変換マップ](https://servicenow-prod.fluidtopics.net/3JMNzrXD~NyZpdvvVtyThw "既存の変換マップ構成を使用して、Kafka 環境からデータをインポートして処理します。")コンシューマーを構成してメッセージを処理するか、Kafka メッセージトリガーを設定してフローを開始できます。

ServiceNow からローカルの Kafka にメッセージをレプリケートする場合は、ワークフロースタジオの を使用するか、ProducerV2 API を使用して、Hermes トピックとローカルの Kafka にメッセージを公開することができます。