Confluent Kafka REST Proxy スポーク

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

    • Confluent Kafka REST Proxy API を介して ServiceNow インスタンスを Kafka クラスターとデータ連携します。

    ストアでアプリを要求する

    ServiceNow Store Web サイトにアクセスして利用可能なすべてのアプリを表示し、ストアにリクエストを送信する方法について確認してください。リリースされたすべてのアプリのリリースノート情報については、「ServiceNow Storeバージョン履歴のリリースノート」を参照してください。

    統合ハブサブスクリプション

    このスポークには Integration Hub のサブスクリプションが必要です。詳細については、「法務スケジュール - IntegrationHub の概要」を参照してください。

    サポートされているバージョン

    このスポークは、Confluent REST プロキシ API v2 用に構築されています。

    スポークの依存関係

    アプリのインストールで問題が発生した場合は、依存プラグイン ServiceNow IntegrationHub Runtime (com.glide.hub.integration.runtime) がインストールされていることを確認してください。

    注:
    このプラグインはライセンス可能な機能であり、スポーク実装の外部で使用する場合は適切なライセンスが必要です。

    スポークのアクション

    Confluent Kafka REST プロキシスポークでは、ServiceNow インスタンスでイベントが発生したときにタスクを自動化するアクションが提供されます。使用可能なアクションは次のとおりです。

    アクション 説明
    コンシューマーインスタンスをトピックパーティションにアサイン このコンシューマーにパーティションのリストを手動でアサインします。
    コンシューマーオフセットをコミット コンシューマーのオフセットのリストをコミットします。投稿本文が空の場合、コンシューマーインスタンスによってフェッチされたすべてのレコードがコミットされます。
    コンシューマーグループ内にコンシューマーインスタンスを作成 Kafka コンシューマーグループ内にコンシューマーインスタンスを作成します。
    コンシューマーインスタンスを削除 コンシューマーインスタンスを破棄します。
    トピックの Kafka パーティションの詳細を取得 Kafka トピックのパーティションの詳細を取得します。
    メッセージを取得 Kafka トピックからメッセージを取得します。
    メッセージを公開 Kafka トピックへのメッセージを生成します。

    接続および資格情報エイリアスの要件

    統合ハブ は、エイリアスを使用して、接続および資格情報を管理します。エイリアスを使用することで、複数の環境を使用する場合に、複数の資格情報と接続情報プロファイルを構成する必要がなくなります。接続または資格情報が変更された場合、接続を使用するどのアクションも更新する必要はありません。詳細については、「資格情報と接続情報」を参照してください。

    スポークの設定については、「 Confluent Kafka REST Proxy スポークのセットアップ。

    Confluent Kafka REST Proxy スポークのセットアップ

    基本 認証を使用して、Confluent Kafka REST プロキシを ServiceNow インスタンスとデータ連携します。

    始める前に

    • 統合ハブ サブスクリプションの要求。
    • Confluent Kafka REST Proxy スポークの有効化。
    • 必要なロール：admin
    注:
    この手順では、基本認証を使用して Confluent Kafka REST Proxy スポークを設定する手順の概要を示します。ただし、カスタマイズに基づいて ServiceNow Platform で現在サポートされている他の HTTP 認証メカニズムを使用してスポークを設定することもできます。

    手順

    1. Confluent Kafka REST ProxySpoke の資格情報レコードを作成します。
      1. 移動先 接続 & 認証情報 > 資格情報.
      2. [新規] をクリックします。
        「作成する資格情報のタイプは？」というメッセージが表示されます。
      3. [基本認証資格情報] を選択します。
        空の基本認証資格情報フォームが表示されます。
      4. 値を入力します。
        フィールド 必要な値
        名前 レコードを一意に識別する名前を入力します。たとえば、「Kafka スポーク資格情報」と入力します。
        ユーザー名 Confluent Kafka REST Proxy API エンドポイントに接続するユーザー名。
        パスワード Confluent Kafka REST Proxy API エンドポイントに接続するパスワード。
        有効 レコードを積極的に使用にするオプション。
        順番 この資格情報を適用する順番。たとえば、「100」と入力します。
      5. [送信] をクリックします。
    2. Confluent Kafka REST ProxySpoke の接続レコードを作成します。
      1. 移動先 接続 & 認証情報 > 接続 & 資格情報エイリアス.
      2. レコード [Kafka REST] を開きます。
      3. [接続] タブで、[新規] をクリックします。
        空の HTTP(s) 接続フォームが表示されます。
      4. 値を入力します。
        フィールド 必要な値
        名前 接続レコードを一意に識別する名前。たとえば、「Kafka スポーク接続」と入力します。
        資格情報 Confluent Kafka REST Proxy スポーク用に作成された資格情報レコード。たとえば、[Kafka スポーク資格情報] を選択します。
        接続 URL Confluent Kafka REST Proxy API に接続するための URL。
      5. [送信] をクリックします。