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

  • リリースバージョン: Xanadu
  • 更新日 2024年08月01日
  • 所要時間：4分

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

    ストリームコネクトメッセージレプリケーションを使用すると、ServiceNow インスタンスから直接メッセージのレプリケーションを設定し、管理できます。

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

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

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

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

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

    ストリームコネクトコネクトレプリケーションは、接続および資格情報エイリアスを使用してローカル 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 Stream Connect Installer [com.glide.hub.stream_connect.installer] プラグインが必要です。

    ロール

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

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

    ログ記録

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