Confluent Kafka ソースを eventstream に追加する

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

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

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

Note

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

前提条件

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

データソースの選択ウィザードを起動する

イベントストリームにまだソースを追加していない場合は、[外部ソースの使用] タイルを選択します。

既に公開されているイベントストリームにソースを追加する場合は、編集モードに切り替え、リボンの [ソースの追加] を選択してから、[外部ソース] を選択します。

Confluent Kafka の構成と接続

[データソースの選択] ページで、[Confluent] を選択します。
Confluent Cloud Kafka ソースへの接続を作成するには、[新しい接続] を選択します。
[接続設定] セクションで、「Confluent Bootstrap Server」と入力します。 Confluent Cloud のホームページに移動し、[クラスター設定] を選択し、アドレスをブートストラップサーバーにコピーします。
[接続資格情報] セクションで、Confluent クラスターへの既存の接続がある場合は、[接続] のドロップダウンリストから選択します。 そうでない場合は、次の手順に従います。
1. 接続名 には、接続の名前を入力します。
2. [認証の種類] で、[Confluent クラウドキー] が選択されていることを確認します。
3. API キーと API キーシークレットの場合:
  1. Confluent クラウドに移動します。
  2. サイドメニューで、[API キー] を選択します。
  3. [追加] ボタンを選択すると、新しいルールが作成されます。
  4. API キーとシークレットをコピーしておきます。
  5. これらの値を [API キー] フィールドと [API キーシークレット] フィールドに貼り付けます。
  6. [接続] を選択します
スクロールして、ページの [Confluent データソースの構成] セクションを表示します。 Confluent データソースの構成を完了するための情報を入力します。
1. [トピック] に、Confluent Cloud のトピック名を入力します。 Confluent Cloud コンソールでトピックを作成または管理できます。
2. コンシューマーグループの場合は、Confluent クラウドのコンシューマーグループを入力します。 Confluent Cloud クラスターからイベントを取得するための専用のコンシューマーグループが用意されています。
3. [自動オフセットのリセット] 設定で、次のいずれかの値を選択します。
  - 最も古い – Confluent クラスターから使用可能な最も古いデータ
  - 最新 – 利用可能な最新のデータ
  - なし – オフセットを自動的に設定しません。
[次へ] を選択します。 [確認と作成] 画面で、概要を確認し、[追加] を選択します。