Amazon MSK Kafka ソースをイベントストリームに追加する

[アーティクル]
11/19/2024

この記事では、Amazon MSK Kafka ソースをイベントストリームに追加する方法について説明します。 

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

Note

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

前提条件

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

Note

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

Amazon MSK Kafka をソースとして追加する

Fabric Real-Time Intelligence で、[イベントストリーム] を選択して新しいイベントストリームを作成します。
次の画面で、外部ソースの追加を選択します。

Amazon MSK Kafka を構成して接続する

[データソース] ページで、[Amazon MSK Kafka] を選択します。
データ接続ページで、新しい接続を選択します。
[接続設定] セクションの [ブートストラップサーバー] に、Kafka クラスターのパブリックエンドポイントを入力します。

パブリックエンドポイントを取得するには:
Amazon MSK Kafka クラスターへの既存の接続がある場合は、[接続の資格情報] セクションで [接続] のドロップダウンリストからそれを選択します。そうでない場合は、次の手順に従います。
1. 接続名 には、接続の名前を入力します。
2. [認証の種類] に [API キー] が選択されていることを確認します。
3. [キー] と [シークレット] に、Amazon MSK Kafka クラスターの API キーとキーのシークレットを入力します。
[接続] を選択します。 
次に、[接続] ページで次の手順に従います。
1. [トピック] に Kafka トピックを入力します。
2. [コンシューマーグループ] に、Kafka クラスターのコンシューマーグループを入力します。このフィールドには、イベントを取得するための専用のコンシューマーグループが用意されています。
3. [自動オフセットのリセット] を選択して、コミットがない場合にオフセットの読み取りを開始する場所を指定します。
4. [セキュリティプロトコル] の場合、既定値は SASL_SSL です。既定の [SASL メカニズム] は SCRAM-SHA-512 であり、変更できません。
[次へ] を選択します。 [確認および接続] 画面で概要を確認し、[接続] を選択します。