Kafka のデータを帳票ツールbiz-Stream で連携利用する方法

CData JDBC ドライバを使って、帳票ツールのbiz-Stream で Kafka をノーコードで連携。

宮本航太
プロダクトスペシャリスト

最終更新日:2022-05-18

この記事で実現できるKafka 連携のシナリオ

こんにちは!プロダクトスペシャリストの宮本です。

biz-Stream は、多様な表現が可能なWeb 帳票ソリューションです。

この記事では、biz-Stream からCData JDBC ドライバ経由でKafka のデータにリアルタイムで連携接続して帳票から利用する方法を紹介します。CData Drivers を使うことで、RDB のようにbiz-Stream 内でKafka のデータを扱うことができるようになります。

biz-Stream へのKafka JDBC ドライバーの配置

デフォルトの内容でインストールした場合、以下のパスに jar ファイルが配置されますので、その jar ファイルを biz-Stream の所定のパスにコピーします。

  • cdata.jdbc.apachekafka.jar
  • cdata.jdbc.apachekafka.lic (試用版では.lic ファイルは不要)
  • コピー元:C:\Program Files\CData\CData JDBC Driver for ApacheKafka 20xxJ\lib
  • コピー先:C:\Program Files (x86)\brainsellers\biz-Stream レイアウト・デザイナ\lib_jdbc

biz-Stream からKafka への接続設定

レイアウトデザイナを起動後、リソース定義にて Kafka への接続設定を行います。ドライバー選択のプルダウンに CData ApacheKafka JDBC Driver が表示されますので選択します。

Apache Kafka 接続プロパティの取得・設定方法

.NET ベースのエディションは、Confluent.Kafka およびlibrdkafka ライブラリに依存して機能します。 これらのアセンブリはインストーラーにバンドルされ、自動的に本製品と一緒にインストールされます。 別のインストール方法を利用する場合は、NuGet から依存関係のあるConfluent.Kafka 2.6.0 をインストールしてください。

Apache Kafka サーバーのアドレスを指定するには、BootstrapServers パラメータを使用します。

デフォルトでは、本製品はデータソースとPLAINTEXT で通信し、これはすべてのデータが暗号化なしで送信されることを意味します。 通信を暗号化するには:

  1. UseSSLtrue に設定し、本製品がSSL 暗号化を使用するように構成します。
  2. SSLServerCert およびSSLServerCertType を設定して、サーバー証明書をロードします。

Apache Kafka への認証

Apache Kafka データソースは、次の認証メソッドをサポートしています:

  • Anonymous
  • Plain
  • SCRAM ログインモジュール
  • SSL クライアント証明書
  • Kerberos

Anonymous

Apache Kafka の特定のオンプレミスデプロイメントでは、認証接続プロパティを設定することなくApache Kafka に接続できます。 こうした接続はanonymous(匿名)と呼ばれます。

匿名認証を行うには、このプロパティを設定します。

  • AuthSchemeNone

その他の認証方法については、ヘルプドキュメントを参照してください。

サーバURLは以下の形式で入力します。
URL: jdbc:apachekafka:User=admin;Password=pass;BootStrapServers=https://localhost:9091;Topic=MyTopic;

Kafka のデータ リソースの作成

JDBC Driver の接続文字列デザイナーを使う

JDBC 接続文字列を作るには、Kafka JDBC Driver のビルトイン接続文字列デザイナーを使う方法があります。ドライバーの.jar ファイルをダブルクリックするか、コマンドラインから.jar ファイルを実行します。

Windows:

java -jar 'C:\Program Files\CData\CData JDBC Driver for ApacheKafka 20xxJ\lib\cdata.jdbc.apachekafka.jar'

MacOS:

java -jar cdata.jdbc.apachekafka.jar

接続プロパティに値を入力して、生成される接続文字列をクリップボードにコピーします。

接続文字列デザイナーを使って、JDBC URL を生成する (Salesforce is shown.)

次にデータ取得条件を設定します。SQL 定義から定義名を設定し、編集ボタンをクリックします。

Kafka のデータ リソースの編集

上のグレーエリアで右クリック → テーブルリストと選択しますと、Kafka のオブジェクトがリストで表示されます。使用するテーブルを選択します。

Kafka のデータ リソースの選択

ここでは取得対象の項目や条件などを設定することができます。対象項目や条件を指定できたらOKボタンをクリックし、戻った画面で追加ボタンをクリックします。

Kafka のデータ のカラム選択と条件設定

最後にデータソース設定を行います。データソース定義名に先ほど設定したものを選択し、画面下部にある追加ボタンをクリックします。これでbiz-Stream でKafka のデータを利用する準備ができました。

データソース設定

Kafka のデータをリアルタイムで参照するbiz-Stream 帳票のデザイン

用紙設定を行います。今回は A4 設定にしました。設定後は画面下部にある追加ボタンをクリックします。

ページ設定では新規ボタンをクリックします。

ここではレイアウトデザイナが帳票テンプレートを xml で保存しますので、ファイル名を設定します。

レイアウトにはさまざまなメニューがありますが、今回は表を使用します。表を設定後、Kafka から取得したデータをセットするエリアを作成します。各セルにテキストボックスを挿入し、そのテキストボックス自体に Kafka の項目を紐づけします。
※ヘッダーにもそれぞれテキストボックスを追加します。

表オブジェクトとしてKafka を使用

レイアウト作成画面を閉じた後、ページ設定の画面に戻りますので、画面下部にある追加ボタン(一度作成している場合は適用)をクリックし、レイアウトの作成が完了となります。

レイアウトデザイナーのトップ画面のヘッダーメニューからプレビューアイコンをクリックします。先ほど作成したレイアウトで Kafka のデータを表示させることができます。

このようにCData JDBC ドライバをアップロードすることで、簡単にbiz-Stream でKafka のデータをリアルタイムに参照する帳票をノーコードで連携して作成することができます。

ぜひ、CData JDBC Driver for ApacheKafka 30日の無償評価版 をダウンロードして、お試しください。

関連コンテンツ

トライアル・お問い合わせ

30日間無償トライアルで、CData のリアルタイムデータ連携をフルにお試しいただけます。記事や製品についてのご質問があればお気軽にお問い合わせください。