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

  • リリースバージョン: Australia
  • 更新日 2026年03月12日
  • 所要時間：7分

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

    始める前に

    • 必要なロール：message_replication_admin
    • この機能には サブスクリプションが必要です。詳細については、「Apache Kafka のストリームコネクトの使用」を参照してください。
    • Hermes メッセージングサービスとインスタンス PKI 証明書ジェネレーターが機能していることを確認します。

    • MID サーバーまたはMID サーバークラスターを構成して開始します。詳細については、「Configuring MID Servers」と「Configure a MID Server cluster」を参照してください。

      MID サーバーは、ファイアウォールを介して Hermes エンドポイントにアクセスできなければなりません。ネットワークアドミニストレーターと協力して、次のポート範囲が開いていることを確認します。
      • プロデューサー： 4000 ～ 4050
      • コンシューマー 1：4100 ～ 4150
      • コンシューマー 2：4200 ～ 4250

      MID サーバー クラスターを使用している場合は、負荷分散のクラスタータイプである必要があります。フェールオーバー クラスターの種類はサポートされていません。

    • ストリームコネクトメッセージレプリケーションは、接続および資格情報エイリアスを使用してローカル Kafka に接続します。[接続タイプ] が [Kafka] のCreate a Connection & Credential alias。接続および資格情報エイリアスには、 Kafka 接続 と Kafka 資格情報が必要です。
    • ストリームコネクトメッセージレプリケーションには、ServiceNow Stream Connect Installer [com.glide.hub.stream_connect.installer] プラグインが必要です。

    このタスクについて

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

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

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

    手順

    1. 移動先 すべて > 統合ハブ > ストリームコネクト > メッセージレプリケーション をクリックし、[ 新規] を選択します。
    2. [メッセージレプリケーション] フォームで、フィールドに入力します。
      表 : 1. メッセージレプリケーションフォーム
      フィールド 説明
      名前 メッセージレプリケーションの名前。
      メッセージングサービス接続 (Messaging service connection) 接続先のメッセージングサービスを指定する接続および資格情報エイリアス。
      アプリケーション メッセージレプリケーションのアプリケーションスコープ。このフィールドは自動的に設定されます。
      アクティブ メッセージのレプリケーションをアクティブ化するオプション。
    3. [Save (保存)] を選択します。
      フォームを保存すると、[メッセージレプリケーションステータス] タブと [Kafka トピックレプリケーション] タブがページの下部に表示されます。
    4. [Kafka トピックレプリケーション (Kafka Topic Replications)] タブで、[新規] を選択します。
    5. [Kafka トピックレプリケーション (Kafka Topic Replications)] フォームで、フィールドに入力します。
      表 : 2. Kafka トピックレプリケーションフォーム
      フィールド 説明
      名前

      トピックレプリケーションの名前。名前は、他のフィールドの値に基づいて自動的に生成されます。

      [名前]を生成するには、[方向]、[ServiceNow トピック (ServiceNow topic)]、および [トピック名] フィールドに値を入力し、[保存] を選択します。

      [方向] が [ServiceNow へ (To ServiceNow)] の場合、名前の形式は、トピック名 [レプリケーション名] -> ServiceNow トピック名 [SN] になります。

      [方向] が [ServiceNow から (From ServiceNow)] の場合、名前の形式は、ServiceNowトピック名 [SN] -> トピック名 [レプリケーション名] になります。
      方向 トピックのレプリケーションの方向。
      • [ServiceNow へ (To ServiceNow)] は、ローカルの Kafka 環境から ServiceNow にトピックをレプリケートします。
      • [ServiceNow から (From ServiceNow)] は、ServiceNow からローカルの Kafka 環境にトピックをレプリケートします。
      ServiceNow トピック Kafka トピック [sys_kafka_topic] テーブルへの参照。
      レプリケーション このトピックのレプリケーションを管理するメッセージレプリケーション。
      トピック名 ローカル Kafka 環境内のトピックの名前。
      アクティブ トピックのレプリケーションをアクティブ化するオプション。
      現在の更新セット内で追跡 選択すると、トピックレプリケーションが現在の更新セットに追加されるため、準本番インスタンスから本番インスタンスに簡単に昇格できます。このフィールドを追加するためにフォームを構成しなければならない場合があります。
    6. [送信] を選択します。
    7. ステップ 1 〜 6 に従って、すべての Kafka クラスターとトピックのメッセージとトピックレプリケーションを作成します。

    タスクの結果

    すべてのメッセージとトピックのレプリケーションレコードを作成したら、メッセージをレプリケートする必要があります。[メッセージレプリケーション] フォームの [メッセージレプリケーションステータス [sys_sc_message_replication_status] タブで、各メッセージレプリケーションのステータス、 MID サーバー、およびエラーメッセージを表示できます。

    Kafka トピックレプリケーションレコードの [チャネルレプリケーションステータス [sys_sc_channel_replication_status] タブで、各トピックレプリケーションのステータスの詳細 ( MID サーバー、 エラーメッセージ、 およびエラー発生時刻 の値など) を表示することもできます。

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

    次のタスク

    ローカルの Kafka から ServiceNow にメッセージをレプリケートする場合は、スクリプト、ETL、または変換マップコンシューマーを構成してメッセージを処理するか、Kafka メッセージトリガーを設定してフローを開始できます。

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