15.2. Kafka ブローカーへのコネクションの作成

インテグレーションで、Kafka トピックからデータをサブスクライブしたり、Kafka トピックにデータを公開するには、Kafka へのコネクションを作成し、そのコネクションをインテグレーションに追加します。

前提条件

  • Kafka ブローカー/AMQ Streams の自動検出の有効化 の説明どおりに、クラスターで Kafka ブローカーの自動検出を有効化済みである必要があります。または、接続する Kafka ブローカーの URI を知っている必要があります。
  • Transport Layer Security (TLS) を使用してデータを暗号化する場合は、Kafka ブローカーの PEM 形式の証明書テキストが必要です。通常、Kafka サーバー管理者からブローカー証明書テキストを取得します。

手順

  1. Fuse Online の左パネルで Connections をクリックし、利用可能なコネクションを表示します。
  2. Create Connection をクリックしてコネクターを表示します。
  3. Kafka Message Broker コネクターをクリックします。
  4. Kafka broker URIs フィールドで、このコネクションがアクセスするブローカーを選択するか、Kafka ブローカー URI のコンマ区切りリストを入力します。各 URI は host:port 形式で指定する必要があります。

  5. Transport Protocol フィールドでは、以下のオプションのいずれかを選択します。

    • 転送中のデータを保護するためにデータを暗号化する場合は、TLS (Transport Layer Security) を選択します。
    • データを暗号化しない場合は、Plain を選択し、7. に進みます。
  6. 5. で TLS を選択した場合、Broker certificate フィールドに Kafka ブローカーの PEM 形式の証明書テキストを貼り付けます。
  7. Validate をクリックします。Fuse Online は即座にコネクションを検証しようとし、検証の成功または失敗を示すメッセージを表示します。検証に失敗した場合は、入力パラメーターを訂正し、再度検証を行います。
  8. 検証に成功した場合は Next をクリックします。
  9. Name フィールドに、このコネクションを別のコネクションと区別するために使用する名前を入力します。たとえば、Kafka West を入力します。
  10. Description は任意のフィールドで、このコネクションに関する便利な情報を入力します。
  11. Save をクリックし、作成したコネクションが利用可能になったことを確認します。上記の例の名前を入力した場合は、インテグレーションに追加できるコネクションとして Kafka West が表示されます。