Infragistics Reveal で Kafka ののデータを分析・可視化
Reveal は Infragistics が提供するデータ可視化ソリューションで、CData API Server と組み合わせることで、リアルタイムのKafka のデータから動的なダッシュボードを構築できます。CData API Server は Kafka 用の OData API を生成し、Reveal からネイティブに利用できます。この記事では、API Server で Kafka に接続し、Infragistics Reveal から API Server に接続してシンプルなダッシュボードを作成する方法を説明します。
API Server から Kafka に接続
CData API Server は、シンプルなポイント&クリック操作のインターフェースでデータソースに接続し、API を生成できます。
- API Server を開き、Settings -> Connection -> Add Connection をクリックします。
- 「Kafka」を選択します。
- Kafka に接続するために必要な認証プロパティを入力します。
Apache Kafka 接続プロパティの取得・設定方法
それでは、Apache Kafka に接続していきましょう。.NET ベースのエディションは、Confluent.Kafka およびlibrdkafka ライブラリに依存して機能します。 これらのアセンブリはインストーラーにバンドルされており、CData 製品と一緒に自動的にインストールされます。 別のインストール方法をご利用の場合は、NuGet から依存関係のあるConfluent.Kafka 2.6.0をインストールしてください。
Apache Kafka サーバーのアドレスを指定するには、BootstrapServers パラメータを使用します。
デフォルトでは、CData 製品はデータソースとPLAINTEXT で通信しており、これはすべてのデータが暗号化なしで送信されることを意味します。 通信を暗号化したい場合は、以下の設定を行ってください:
- UseSSL をtrue に設定し、CData 製品がSSL 暗号化を使用するように構成します
- SSLServerCert およびSSLServerCertType を設定して、サーバー証明書をロードします
Apache Kafka への認証
続いて、認証方法を設定しましょう。Apache Kafka データソースでは、以下の認証方法をサポートしています:
- Anonymous
- Plain
- SCRAM ログインモジュール
- SSL クライアント証明書
- Kerberos
Anonymous 認証
Apache Kafka の特定のオンプレミスデプロイメントでは、認証接続プロパティを設定することなくApache Kafka に接続できます。 このような接続はanonymous(匿名)と呼ばれます。
匿名認証を行うには、以下のプロパティを設定してください。
- AuthScheme:None
その他の認証方法については、ヘルプドキュメントをご確認ください。
API Server で Kafka のリソース定義を追加
Kafka に接続したら、Kafka のデータ の API エンドポイントとなるリソースを作成します。
- Settings -> Resources -> Add Resource をクリックします。
- Kafka の接続を選択します。
- 取得したいテーブルを選択し、「次へ」をクリックします。
- (オプション) リソースを編集して、特定のフィールドを選択するなどの設定を行います。
- 設定を保存します。
API Server ユーザーの追加
API Server 経由で Reveal から Kafka に接続するためのユーザーを作成します。
- Settings -> Users をクリックします。
- Add をクリックします。
- Kafka の接続とリソースにアクセス可能なユーザーを設定します。
(オプション) クロスオリジンリソースシェアリング (CORS) の設定
Ajax などのアプリケーションから複数の異なるドメインにアクセス・接続する場合、クロスサイトスクリプティングの制限に抵触する可能性があります。その場合は、Settings -> Server で CORS 設定を行います。
- Enable cross-origin resource sharing (CORS): ON
- Allow all domains without '*': ON
- Access-Control-Allow-Methods: GET, PUT, POST, OPTIONS
- Access-Control-Allow-Headers: Authorization
設定の変更を保存します。
Reveal でダッシュボードを作成
API Server の設定が完了したら、Reveal でKafka のデータを可視化していきましょう。
- Reveal にログインし、Dashboards -> New をクリックします。
- Data Source -> OData Feed をクリックします。
- API Server の API エンドポイント URL を指定します。例: https://serverurl/api.rsc
- Generic Credentials を選択し、API Server のユーザー名と認証トークンを指定します。
- 可視化したいエンティティを選択します。
- フィールドを選択し、チャートタイプを選びます。
詳細情報と無償トライアル
これで、リアルタイムのKafka のデータからシンプルなダッシュボードを作成できました。Kafka (および 150 以上のデータソース) から OData フィードを作成する方法の詳細については、API Server ページをご覧ください。30日間の無償トライアルをダウンロードして、OData API を利用するツールでリアルタイムのKafka のデータを活用してみてください。