MySQL Workbench でKafka データをクエリ

詳細情報をご希望ですか?

無償トライアル:

ダウンロードへ

製品の詳細情報へ:

Apache Kafka ODBC Driver

Apache Kafka ODBC Driver を使って、ODBC 接続をサポートするあらゆるアプリケーション・ツールからApache Kafka にデータ連携。

Apache Kafka データストリームにデータベースと同感覚でアクセスして、トピックに使い慣れたODBC インターフェースで双方向連携。



MySQL Workbench からライブKafka データにMySQL クエリを実行します。

ODBC Driver for Kafka から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 PlainUser およびPassword プロパティを指定する必要があります。AuthScheme は'Plain' に設定します。
  • SASL SSLUser およびPassword プロパティを指定する必要があります。AuthScheme は'Scram' に、UseSSL はtrue に設定します。
  • SSLSSLCert およびSSLCertPassword プロパティを指定する必要があります。UseSSL はtrue に設定します。
  • KerberosUser および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 Kafka)に名前を付けます。
  3. HostnamePortUsername のパラメータを設定し、SQL Gateway に接続します。
  4. Store in Vault をクリックしてパスワードを設定し、保存します。
  5. Test Connection をクリックして接続が正しく構成されていることを確認し、OK をクリックします。

Kafka データをクエリ

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

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