Kafka ターゲット

コネクタを構成するには、次の手順を実行します。

1. [接続] で、 [接続を作成] をクリックします。

2. Kafka ターゲット コネクタを選択し、次の設定を行います。

データ ターゲット

データ ゲートウェイ

Amazon MSK にデータを移動する場合、Data Movement gateway が必要になるのは、Amazon MSK が Qlik Cloud からアクセスできず、プライベート リンクを使用してのみアクセスできる場合 (仮想プライベートクラウド内にある場合など) のみです。このような場合は、ターゲット データベースにアクセスする Data Movement gateway を選択します。ユースケースに応じて、これはデータ ソースからデータを移動するために展開された、同じまたは別の Data Movement gateway になります。

Qlik Cloud から直接アクセスできる Amazon MSK インスタンスにデータを移動する場合は、 [なし] を選択します。

Data Movement gateway のユース ケースに関する詳細については、「どのようなときに Data Movement gateway が必要ですか？」および「一般的な使用例」を参照してください。

[Cloud provider] (クラウドプロバイダー)

オンプレミスの Kafka を使用する場合は [なし] を、Amazon MSK を使用する場合は [Amazon MSK] を選択します。

ブローカー サーバー

1 つ以上のブローカー サーバーを次の形式で指定します (高可用性のため)。

server1[:port1][,server2[:port2]]

例:

192.168.1.100:9092,192.168.1.101:9093

データタスクは、最初に利用可能なホストに接続します。ポートを指定せずにホストが指定された場合、ポート 9092 が既定として使用されます。

アカウントのプロパティ

認証方法

次のいずれかを選択します。

• なし: 認証なし。

• 証明書に設定して有効にします。このオプションを選択した場合は、次の情報も提供する必要があります。

  メモ  パブリック キー ファイルとプライベートキー ファイルは PEM 形式である必要があります。

  • パブリック キー ファイル: PEM 形式のパブリック キー ファイルを参照します。[保存] をクリックすると、ファイルは Qlik Talend Cloud にアップロードされ、コネクタ設定で選択された Data Movement gateway に展開されます。
  • プライベートキーファイルに設定して有効にします。PEM 形式のプライベート キー ファイルを参照します。[保存] をクリックすると、ファイルは Qlik Talend Cloud にアップロードされ、コネクタ設定で選択された Data Movement gateway に展開されます。
  • プライベート キー パスワードに設定して有効にします。プライベート キー ファイルのパスワード。

• Kerberos (SASL/GSSAPI): Kerberos を使用して Kafka クラスターに対して認証をする場合に選択します。

  情報メモ

  選択された [クラウド プロバイダー] が [Amazon MSK] の場合、この認証方法は使用できません。

  • プリンシパル: ブローカー サーバーに対して認証するために使用される Kerberos プリンシパル。
  • keytab ファイル: Keytab ファイルを参照します。[保存] をクリックすると、ファイルは Qlik Talend Cloud にアップロードされ、コネクタ設定で選択された Data Movement gateway に展開されます。
  情報メモ

  Linux で Kerberos 認証を使用するには、Kerberos クライアント (ワークステーション) パッケージがインストールされている必要があります。

• ユーザー名とパスワード (SASL/PLAIN): このオプションを選択すると、ユーザー名とパスワード (SASL/PLAIN) を使用して認証できます。パスワードが平文で送信されるのを防ぐため、 [TLS を有効にする] オプションも有効にすることを強くお勧めします。

  情報メモ

  選択した [クラウド プロバイダー] が [Amazon MSK] の場合、この認証方法は使用できません。

• ユーザー名とパスワード (SASL/SCRAM-SHA-256): このオプションを選択すると、ユーザー名とパスワード (SASL/SCRAM-SHA-256) を使用して認証できます。

  このオプションを選択する場合は、各ブローカーの server.properties ファイルにも対応する SASL/SCRAM メカニズムを設定する必要があります。

  情報メモ

  選択した [クラウド プロバイダー] が [Amazon MSK] の場合、この認証方法は使用できません。

• ユーザー名とパスワード (SASL/SCRAM-SHA-512): このオプションを選択すると、ユーザー名とパスワード (SASL/SCRAM-SHA-512) を使用して認証できます。

  このオプションを選択する場合は、各ブローカーの server.properties ファイルにも対応する SASL/SCRAM メカニズムを設定する必要があります。

SSL オプション

TLS を有効にする (TLS 1.0、1.1、1.2 をサポート)

このオプションは、Qlik Talend Cloud とブローカー サーバー間の通信を暗号化する場合に選択します。ブローカーが SSL を要求するように構成されている場合、このオプションを必ず選択してください。

• CA ファイル: PEM 形式の CA 証明書を参照します。[保存] をクリックすると、ファイルは Qlik Talend Cloud にアップロードされ、コネクタ設定で選択された Data Movement gateway に展開されます。

  情報メモ

  選択した [クラウド プロバイダー] が [Amazon MSK] の場合は必要ありません。

メタデータ メッセージの公開

公開にスキーマ レジストリに使用できるメタデータ メッセージ

ドロップダウン リストから、次のオプションのいずれかを選択します。

• いいえ

  このオプションを選択すると、データ メッセージのみが公開されます。

• Confluent Schema Registry

  このオプションを選択する場合は、以下に説明するスキーマ レジストリ接続プロパティも構成する必要があります。

メッセージ形式

メッセージ形式として JSON または Avro を選択します。Confluent Schema Registry を選択した場合、Avro のみが利用可能なオプションになります。

スキーマ レジストリ接続プロパティ

スキーマ レジストリ サーバー

1 つ以上のスキーマ レジストリ サーバーを次の形式で指定します (高可用性のため)。

Confluent Schema Registry にデータ スキーマを公開する場合:

server1:port1[,server2[:port2]]

192.168.1.100:8081,192.168.1.101:8081

データタスクは、最初に利用可能なホストに接続します。

Hortonworks Schema Registry にデータ スキーマを公開する場合:

server1:port1[,server2[:port2]]

192.168.1.100:7788,192.168.1.101:7788

データタスクは、最初に利用可能なホストに接続します。

認証方法

次のスキーマ レジストリ認証オプションのいずれかを選択します。

• なし: 認証なし。

• Kerberos: Kerberos を使用して認証する場合に選択します。

  情報メモ

  Linux で Kerberos 認証を使用するには、Kerberos クライアント (ワークステーション) パッケージがインストールされている必要があります。

• プリンシパル: スキーマ レジストリに対して認証するために使用される Kerberos プリンシパル。

• Keytab ファイル: Keytab ファイルを参照します。[保存] をクリックすると、ファイルは Qlik Talend Cloud にアップロードされ、コネクタ設定で選択された Data Movement gateway に展開されます。

• 証明書: 証明書を使用して認証する場合に選択します。

  情報メモ

  このオプションは、Confluent Schema Registryに公開する場合にのみサポートされます。

  このオプションを選択した場合は、次の情報も提供する必要があります。

• パブリック キー ファイル: PEM 形式のパブリック キー ファイルを参照します。[保存] をクリックすると、ファイルは Qlik Talend Cloud にアップロードされ、コネクタ設定で選択された Data Movement gateway に展開されます。
• プライベート キー ファイル: PEM 形式のプライベート キー ファイルを参照します。[保存] をクリックすると、ファイルは Qlik Talend Cloud にアップロードされ、コネクタ設定で選択された Data Movement gateway に展開されます。
• プライベート キー パスワード: プライベート キー ファイルのパスワード。

• ユーザー名とパスワード: ユーザー名とパスワードで認証する場合に選択します。次に、 [ユーザー名] と [パスワード] 項目にログイン資格情報を入力します。

  情報メモ

  このオプションは、Confluent Schema Registry に公開する場合にのみサポートされます。

• 証明書 + ユーザー名とパスワード: 証明書とユーザー名とパスワードの両方を使用して認証する場合に選択します。

  このオプションを選択した場合、上記の [パブリック キー ファイル]、 [プライベート キー ファイル]、 [プライベート キー パスワード]、 [ユーザー名]、 [パスワード] 項目に必須情報を入力します。

  情報メモ

  このオプションは、Confluent Schema Registry に公開する場合にのみサポートされます。

• TLS を有効にする (TLS 1.0、1.1、1.2 をサポート): Data Movement gateway マシンとスキーマ レジストリ サーバー間のデータを暗号化するには、このオプションを選択します。サーバーが SSL を要求するように構成されている場合、このオプションを必ず選択してください。

  • CAファイル: PEM 形式の CA 証明書を参照します。[保存] をクリックすると、ファイルは Qlik Talend Cloud にアップロードされ、コネクタ設定で選択された Data Movement gateway に展開されます。

内部プロパティ

内部プロパティは、特殊なユース ケース向けであるため、ダイアログで公開されません。Qlik サポートによって指示があった場合にのみ使用する必要があります。

項目右側にある と ボタンを使用して、必要に応じてプロパティを追加したり削除したりします。

名前

接続の表示名です。

前提条件