次の方法で共有


Confluent Kafka ソースを eventstream に追加する (プレビュー)

この記事では、カスタム アプリ ソースを Eventstream に追加する方法について説明します。

Confluent Cloud Kafka は、Apache Kafka を使用した強力なデータ ストリーミングと処理機能を提供するストリーミング プラットフォームです。 Confluent Cloud Kafka をイベントストリーム内のソースとして統合することで、リアルタイム データ ストリームをシームレスに処理してから、Fabric 内の複数の宛先にルーティングできます。

重要

Fabric イベント ストリームの拡張機能は現在プレビュー段階です。

Note

このソースは、ワークスペース容量の次のリージョンではサポートされていません: 米国西部 3スイス西部

前提条件

  • 投稿者以上の権限を持つ Fabric プレミアム ワークスペースへのアクセス権
  • Confluent Cloud Kafka クラスターと API キー。
  • ご利用の Confluent Cloud Kafka クラスターはパブリックにアクセス可能であり、ファイアウォールの内側には置かれておらず、仮想ネットワーク内で保護されていない必要があります。

Note

1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。

Confluent Cloud Kafka をソースとして追加する

  1. プレビュートグルを選択してイベントストリームを作成します。
  2. [外部ソースの追加] を選択 します

Confluent Kafka の構成と接続

  1. [データ ソースの選択] ページで、[Confluent] を選択します。

    イベントの取得ウィザードでソースの種類としての Confluent の選択を示すスクリーンショット。

  2. Confluent Cloud Kafka ソースへの接続を作成するには、[新しい接続] を選択します

    イベントの取得ウィザードの [接続] ページで [新しい接続] リンクの選択を示すスクリーンショット。

  3. [接続設定] セクションで、「Confluent Bootstrap Server」と入力します。 Confluent Cloud のホーム ページに移動し、[クラスター 設定] を選択し、アドレスをブートストラップ サーバーにコピーします。

  4. [接続資格情報] セクションで、Confluent クラスターへの既存の接続がある場合は、[接続] のドロップダウン リストから選択します そうでない場合は、次の手順に従います。

    1. 接続名 には、接続の名前を入力します。
    2. [認証の種類] で、[Confluent クラウド キー] が選択されていることを確認します。
    3. API キーと API キー シークレットの場合:
      1. Confluent クラウドに移動します。

      2. サイド メニューで、[API キー] を選択します。

      3. [追加] ボタンを選択すると、新しいルールが作成されます。

      4. API キーシークレットをコピーしておきます。

      5. これらの値を [API キー] フィールドと [API キー シークレット] フィールドに貼り付けます。

      6. 接続を選択します

        Confluent 接続設定の最初のページを示すスクリーンショット。

  5. スクロールして、ページの [Confluent データ ソースの構成] セクションを表示します。 Confluent データ ソースの構成を完了するための情報を入力します。

    1. [トピック]、Confluent Cloud のトピック名を入力します。 Confluent Cloud コンソールでトピックを作成または管理できます。
    2. コンシューマー グループの場合は、Confluent クラウドのコンシューマー グループを入力します。 Confluent Cloud クラスターからイベントを取得するための専用のコンシューマー グループが用意されています。
    3. [自動オフセットのリセット] 設定で、次のいずれかの値を選択します。
      • 最も古い – Confluent クラスターから使用可能な最も古いデータ

      • 最新 – 利用可能な最新のデータ

      • なし – オフセットを自動的に設定しません。

        Confluent 接続設定の 2 番目のページ (Confluent データ ソースの構成ページ) を示すスクリーンショット。

  6. [次へ] を選択します。 [確認と作成] 画面で、概要を確認し、[追加] を選択します。

Confluent Cloud Kafka ソースが、編集モードキャンバス上の eventstream に追加されていることがわかります。 この新しく追加された Confluent Cloud Kafka ソースを実装するには、リボンの [発行] を選択します。

編集ビューの Confluent Kafka ソースを示すスクリーンショット。

これらの手順を完了すると、Confluent Cloud Kafka ソースを[ライブ ビュー] で視覚化できるようになります。

ライブ ビューの Confluent Kafka ソースを示すスクリーンショット。

その他のコネクタ。