Amazon Managed Streaming for Apache Kafka (MSK) をリアルタイム ハブのソースとして追加する

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

Amazon MSK Kafka は、セットアップ、スケーリング、管理を簡素化するフル マネージドの Kafka サービスです。 Amazon MSK Kafka をイベント ストリーム内のソースとして統合すると、MSK Kafka からリアルタイム イベントをシームレスに取り込み、Fabric 内の複数の宛先にルーティングする前にそれを処理できます。 

前提条件

• 共同作成者以上のアクセス許可を使用した Fabric 容量ライセンス モード (または試用版ライセンス モード) でのワークスペースへのアクセス。
• アクティブな状態の Amazon MSK Kafka クラスター。
• ご利用の Amazon MSK Kafka クラスターはパブリックにアクセス可能であり、ファイアウォールの内側には置かれておらず、仮想ネットワーク内で保護されていない必要があります。

データ ソース ページ

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

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

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

   

Amazon Managed Streaming for Apache Kafka をソースとして追加する

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

   

2. データ 接続ページで、新しい接続を選択します。

   

3. [接続設定] セクションの [ブートストラップ サーバー] に、Kafka クラスターのパブリック エンドポイントを入力します。

   

   パブリック エンドポイントを取得するには:

   

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

   1. 接続名 には、接続の名前を入力します。
   2. [認証の種類] に [API キー] が選択されていることを確認します。
   3. [キー] と [シークレット] に、Amazon MSK Kafka クラスターの API キーとキーのシークレットを入力します。

5. [接続] を選択します。 

6. 次に、[接続] ページで次の手順に従います。

   1. [トピック] に Kafka トピックを入力します。

   2. [コンシューマー グループ] に、Kafka クラスターのコンシューマー グループを入力します。 このフィールドには、イベントを取得するための専用のコンシューマー グループが用意されています。

   3. [自動オフセットのリセット] を選択して、コミットがない場合にオフセットの読み取りを開始する場所を指定します。

   4. [セキュリティ プロトコル] の場合、既定値は SASL_SSL です。 既定の [SASL メカニズム] は SCRAM-SHA-512 であり、変更できません。

      

7. [次へ] を選択します。 [確認および接続] 画面で概要を確認し、[接続] を選択します。

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

1. [確認および接続] ページで [イベントストリームを開く] を選択すると、ウィザードに選択した Amazon Managed Streaming for Apache Kafka ソースを使用して作成したイベントストリームが表示されます。 ページの下部の [閉じる] をクリックしてウィザードを終了します。

2. リアルタイム ハブで、リアルタイム ハブの [データ ストリーム] タブに切り替えます。 ページを最新の情報に更新します。 作成されたデータ ストリームが表示されます。

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

関連するコンテンツ

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

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