Confluent Cloud Kafka をリアルタイム ハブのソースとして追加する

この記事では、Fabric リアルタイム ハブで Confluent Cloud Kafka をイベント ソースとして追加する方法について説明します。

前提条件

• 共同作成者以上のアクセス許可を使用した Fabric 容量ライセンス モード (または試用版ライセンス モード) でのワークスペースへのアクセス。
• Confluent Cloud Kafka クラスターと API キー。

データ ソース ページ

1. Microsoft Fabric にサインインします。

2. 左側のナビゲーション バーで [リアルタイム] を選択します。

3. [リアルタイム ハブ] ページで、左側のナビゲーション メニューの [接続先] の下にある [+ データ ソース] を選択します。 また、右上にある [+ データ ソースに接続] ボタンを選択して、[すべてのデータ ストリーム] ページまたは [マイ データ ストリーム] ページから [データ ソース] ページにアクセスすることもできます。

   

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

1. [データ ソースの選択] ページで、[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. [接続] を選択します

         

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

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

      • 最も古い – Confluent クラスターから使用可能な最も古いデータ

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

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

        

6. 右側のペインの [ストリームの詳細] セクションで、次の手順を実行します。

   1. 接続を保存するワークスペースを選択します。

   2. 自動的に作成されるEventstreamの名前を入力します。

   3. リアルタイム ハブのストリームの名前が自動的に生成されます。

      

7. [次へ] を選択します。

8. [確認と接続] ページで概要を確認してから、[接続] を選択します。

データ ストリームの詳細を表示する

1. [確認と接続] ページで、[イベントストリームを開く] を選択した場合、選択した Confluent Cloud Kafka ソースで作成したイベントストリームがウィザードで開きます。 ページの下部の [閉じる] をクリックしてウィザードを終了します。

2. リアルタイム ハブで、[すべてのデータ ストリーム] を選択します。 新しいデータ ストリームを表示するには、[すべてのデータ ストリーム] ページを最新の情報に更新します。

   詳細な手順については、「Fabric リアルタイム ハブでのデータ ストリームの詳細の表示」を参照してください。

関連するコンテンツ

データ ストリームの使用について詳しくは、次の記事を参照してください。

• データ ストリームの処理
• データ ストリームを分析する
• データ ストリームにアラートを設定する