MySQL Workbench でKafka データをクエリ

ODBC Driver for ApacheKafka からSQL Gateway を使用し、MySQL インターフェースを介してKafka にクエリを実行できます。以下のステップに従って、SQL Gateway のMySQL リモーティングサービスを開始し、MySQL Workbench でライブKafka を操作します。

Kafka データへの接続

未指定の場合は、データソース名（DSN）で必要な接続プロパティの値を指定します。DSN を構成するために、ビルトインのMicrosoft ODBC Data Source Administrator を使用できます。ドライバーのインストールの最後にアドミニストレーターが開きます。Microsoft ODBC データソースアドミニストレーターでDSN を作成及び設定する方法については、ヘルプドキュメントの［はじめに］チャプターを参照してください。

BootstrapServers およびTopic プロパティを設定して、Apache Kafka サーバーのアドレスと、対話するトピックを指定します。

認可メカニズム

• SASL Plain：User およびPassword プロパティを指定する必要があります。AuthScheme は'Plain' に設定します。
• SASL SSL：User およびPassword プロパティを指定する必要があります。AuthScheme は'Scram' に、UseSSL はtrue に設定します。
• SSL：SSLCert およびSSLCertPassword プロパティを指定する必要があります。UseSSL はtrue に設定します。
• Kerberos：User およびPassword プロパティを指定する必要があります。AuthScheme は'Kerberos' に設定します。

サーバー証明書を信頼する必要がある場合があります。そのような場合は、必要に応じてTrustStorePath およびTrustStorePassword を指定してください。

SQL Gateway を構成する

Kafka への接続を仮想MySQL データベースとして設定するには、SQL Gateway Overview を参照してください。クライアントからのMySQL 要求を受けるMySQL リモートサービスを構成します。このサービスは、SQL Gateway UI で構成できます。

MySQL Workbench からKafka をクエリ

以下のステップでは、MySQL Workbench からSQL Gateway で作成された仮想Kafka データベースに接続し、ライブKafka データを操作するための基本的なクエリを発行する方法を説明します。

SQL Gateway を介してKafka に接続

1. MySQL Workbench で、［add a new MySQL connection］をクリックします。
2. 接続（CData SQL Gateway for ApacheKafka）に名前を付けます。
3. Hostname、Port、Username のパラメータを設定し、SQL Gateway に接続します。
4. Store in Vault をクリックしてパスワードを設定し、保存します。
5. Test Connection をクリックして接続が正しく構成されていることを確認し、OK をクリックします。

Kafka データをクエリ

1. 作成した接続（CData SQL Gateway for ApacheKafka）を開きます。
2. ［File］->［New Query Tab］と進みます。
3. SELECT * FROM `CData ApacheKafka Sys`.SampleTable_1; のようなKafka データを取得するSQL クエリを記述します。

MySQL Workbench からライブKafka データにアクセスすることで、MySQL データベースと同じようにKafka をクエリおよび更新できます。CData ODBC Driver for ApacheKafka とCData SQL Gateway の30日の無償評価版はこちらです。