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 をソースとして追加する
- プレビュートグルを選択してイベントストリームを作成します。
- [外部ソースの追加] を選択 します。
Confluent Kafka の構成と接続
[データ ソースの選択] ページで、[Confluent] を選択します。
Confluent Cloud Kafka ソースへの接続を作成するには、[新しい接続] を選択します。
[接続設定] セクションで、「Confluent Bootstrap Server」と入力します。 Confluent Cloud のホーム ページに移動し、[クラスター 設定] を選択し、アドレスをブートストラップ サーバーにコピーします。
[接続資格情報] セクションで、Confluent クラスターへの既存の接続がある場合は、[接続] のドロップダウン リストから選択します。 そうでない場合は、次の手順に従います。
- 接続名 には、接続の名前を入力します。
- [認証の種類] で、[Confluent クラウド キー] が選択されていることを確認します。
- API キーと API キー シークレットの場合:
Confluent クラウドに移動します。
サイド メニューで、[API キー] を選択します。
[追加] ボタンを選択すると、新しいルールが作成されます。
API キーとシークレットをコピーしておきます。
これらの値を [API キー] フィールドと [API キー シークレット] フィールドに貼り付けます。
接続を選択します
スクロールして、ページの [Confluent データ ソースの構成] セクションを表示します。 Confluent データ ソースの構成を完了するための情報を入力します。
- [トピック] に、Confluent Cloud のトピック名を入力します。 Confluent Cloud コンソールでトピックを作成または管理できます。
- コンシューマー グループの場合は、Confluent クラウドのコンシューマー グループを入力します。 Confluent Cloud クラスターからイベントを取得するための専用のコンシューマー グループが用意されています。
- [自動オフセットのリセット] 設定で、次のいずれかの値を選択します。
最も古い – Confluent クラスターから使用可能な最も古いデータ
最新 – 利用可能な最新のデータ
なし – オフセットを自動的に設定しません。
[次へ] を選択します。 [確認と作成] 画面で、概要を確認し、[追加] を選択します。
Confluent Cloud Kafka ソースが、編集モードでキャンバス上の eventstream に追加されていることがわかります。 この新しく追加された Confluent Cloud Kafka ソースを実装するには、リボンの [発行] を選択します。
これらの手順を完了すると、Confluent Cloud Kafka ソースを[ライブ ビュー] で視覚化できるようになります。
関連するコンテンツ
その他のコネクタ。