Stream Connect Message Replication

  • リリースバージョン: Washingtondc
  • 更新日 2024年02月01日
  • 読む4読むのに数分

    • 環境 Apache Kafka と ServiceNowの間でデータをレプリケートします。

    Stream Connect Message Replication を使用すると、インスタンスから直接 ServiceNow メッセージのレプリケーションを設定および管理できます。

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

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

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

    ファイアウォール MID サーバー を介してエンドポイントにアクセスできる Hermes 必要があります。ネットワーク管理者と協力して、次のポート範囲が開いていることを確認します。
    • プロデューサー: 4000–4050
    • コンシューマー1: 4100–4150
    • コンシューマー2: 4200–4250

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

    Stream Connect Message Replication は、Connection & Credential Alias を使用してローカル 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] テーブルに格納されます。

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

    メッセージ複製統計の表示

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

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

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

    必須のプラグイン

    Stream Connect Message Replication には、 ServiceNow Stream Connect Replication - Kafka [com.glide.hub.stream_connect.replication.kafka] プラグインが必要です。

    ロール

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

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

    ログ記録

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