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

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

始める前に

• 必要なロール：message_replication_admin
• この機能には サブスクリプションが必要です。詳細については、「Apache Kafka のストリームコネクトの使用」を参照してください。
• Hermes メッセージングサービスとインスタンス PKI 証明書ジェネレーターが機能していることを確認します。
  • Check the status of and connection to the Hermes Kafka cluster。
  • Key Management Framework Healthをチェックして、インスタンス PKI セクションの 3 つの項目すべてが動作していることを確認します。
• MID サーバーを構成して開始します。詳細については、「Configuring MID Servers」を参照してください。MID サーバーは、ファイアウォールを介して Hermes エンドポイントにアクセスできなければなりません。ネットワークアドミニストレーターと協力して、次のポート範囲が開いていることを確認します。
  • プロデューサー： 4000 ～ 4050
  • コンシューマー 1：4100 ～ 4150
  • コンシューマー 2：4200 ～ 4250
• ストリームコネクトメッセージレプリケーションは、接続および資格情報エイリアスを使用してローカル Kafka に接続します。[接続タイプ] が [Kafka] のCreate a Connection & Credential alias。接続および資格情報エイリアスには、 [Kafka 接続 (Kafka Connection)] と [Kafka SSL 認証情報]が必要です。
• ストリームコネクトメッセージレプリケーションには、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. 移動先 すべて > 統合ハブ > Stream Connect > メッセージレプリケーション をクリックし、[ New] を選択します。
2. [メッセージレプリケーション] フォームで、フィールドに入力します。

   表 : 1. メッセージレプリケーションフォーム

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

3. [保存] を選択します。
   フォームを保存すると、[Kafka トピックレプリケーション (Kafka Topic Replications)] タブがページの下部に表示されます。
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 環境内のトピックの名前。
   アクティブ	トピックのレプリケーションをアクティブ化するオプション。
   状況	トピックレプリケーションの前回の既知のステータス。このフィールドは自動的に設定されます。
   エラーメッセージ	トピックレプリケーションの前回の既知のステータスに基づいたエラーメッセージ。このフィールドは自動的に設定されます。
   現在の更新セット内で追跡 (Track in current update set)	選択すると、トピックレプリケーションが現在の更新セットに追加されるため、準本番インスタンスから本番インスタンスに簡単に昇格できます。このフィールドを追加するためにフォームを構成しなければならない場合があります。

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

タスクの結果

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

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

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

次のタスク

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

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