ストリームコネクト メッセージレプリケーション

  • リリースバージョン: Zurich
  • 更新日 2025年07月31日
  • 所要時間：5分

    • Apache Kafka 環境と ServiceNow の間でデータを複製します。

    ストリームコネクト Message Replication を使用すると、ServiceNow インスタンスから直接メッセージのレプリケーションを構成および管理できます。

    ストリームコネクト メッセージレプリケーションは、 MID サーバー または MID サーバー クラスターを使用してデータレプリケーションを実行するため、追加のレプリケーションサービスを構成またはホストする必要はありません。また、必要な証明書が自動的に生成されるため、メッセージレプリケーションのセットアップが簡略化されます。

    MID サーバーによるデータの複製の有効化

    ストリームコネクト メッセージレプリケーションでは、レプリケーター拡張機能を持つ MID サーバー を使用して、ローカルの Kafka との間でデータを複製します。MID サーバーの構成方法については、「Configuring MID Servers」を参照してください。

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

    MID サーバー クラスターの使用

    メッセージレプリケーションには、単一のMID サーバーの代わりにMID サーバークラスターを使用できます。MID サーバークラスターでは、クラスター内のMID サーバーの 1 つに障害が発生した場合、他のMID サーバーが障害が発生したMID サーバーの負荷を共有できます。

    MID サーバークラスターでは、トピックパーティションはクラスター内の利用可能なすべてのMID サーバーに分散されます。MID サーバーが利用できなくなった場合、パーティションは残りのMID サーバーに再配分されます。クラスターで追加の MID サーバー が使用可能になると、パーティションは再び MID サーバー に分散されます。

    MID サーバー クラスターの設定の詳細については、「Configure a MID Server cluster」を参照してください。
    注:
    MID サーバークラスターには、負荷分散クラスタータイプが必要です。フェールオーバー クラスターの種類はサポートされていません。

    Kafka の接続と資格情報の構成

    ストリームコネクト Message Replication は、接続および資格情報エイリアスを使用してローカル Kafka に接続します。接続および資格情報エイリアスの構成方法：
    1. 接続に必要な認証データを使用して、Kafka SSL 認証情報の作成。
    2. Kafka 接続の構成を行い、Kafka 環境に接続します。
    3. Create a Connection & Credential aliasを行い、接続情報と認証情報データを関連付けます。接続および資格情報エイリアスの [接続タイプ]は [Kafka] で、MID サーバーからアクセスできる必要があります。

    これらの手順は、Kafka に接続するための接続および資格情報エイリアスを構成するためのものです。必要なキーストア、トラストストア、証明書の作成を MID サーバーが自動的に処理するため、Hermes に接続するための接続や認証情報を設定する必要はありません。

    メッセージおよびトピックのレプリケーションの作成

    メッセージレプリケーションには、メッセージレプリケーションレコードと Kafka トピックレプリケーションレコードが必要です。

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

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

    メッセージおよびトピックのレプリケーションレコードを作成するためのステップバイステップのガイドについては、「ストリームコネクトでメッセージと Kafka トピックレプリケーションを作成する」を参照してください。

    メッセージレプリケーション統計情報の表示

    レプリケーションが実行されると、各アクティブなトピックのレプリケーションにメトリクスレコードが 60 秒ごとに作成されます。メトリクスレコードは、各収集間隔で複製されたメッセージの数を示す [メッセージ数] など、トピックのレプリケーションに関する情報を提供します。

    メトリクスレコードは、メッセージレプリケーション統計情報 [sys_sc_channel_replication_metric] テーブルで表示できます。Kafka トピックレプリケーションレコードのメッセージレプリケーション統計情報を確認することで、特定のトピックのメトリクスレコードを表示することもできます。

    メッセージレプリケーションメトリクスとその説明のリストについては、「ストリームコネクトメッセージレプリケーション統計情報の表示」を参照してください。

    必須のプラグイン

    ストリームコネクト メッセージレプリケーションには、 ServiceNow ストリームコネクト インストーラー [com.glide.hub.stream_connect.installer] プラグインが必要です。

    ロール

    message_replication_admin ロールは、接続と資格情報テーブル、メッセージとトピックのレプリケーションテーブルなど、すべてのメッセージレプリケーションテーブルのレコードを作成、変更、削除できます。

    message_replication_user ロールは、メッセージレプリケーションテーブルのレコードを表示できます。

    ログ記録

    ほとんどの問題は MID サーバーログに記録されます。追加のデバッグログ記録を有効にするには、 glide.stream_connect.message_replication.debug MID サーバープロパティを [true] に設定します。