Zen Kafka JDBC Dialect

Apache Kafka と Actian Zen データベースを連携させるためのコネクティビティ・ソリューションです。「JDBC Dialect (SQL準拠)」と「Btrieve Native Connector (高速API)」の 2つの接続方式を提供しています。

本ページでは、主に汎用性と導入の容易さに優れた JDBC Dialect の設定方法を中心に、両方式を比較しながら説明します。

Zen Kafka JDBC Dialect について

Zen Kafka JDBC Dialect は、Confluent JDBC Connector の機能を拡張し、Zen 固有の SQL 方言を理解させるためのプラグインです。

主な機能

• Upsert (Merge) サポート: キー重複時には UPDATE、重複しない時には INSERT を行う処理を、Zen の SQL 構文に合わせて自動生成します。
• ネイティブ型マッピング: Kafka のデータ型を Zen に最適な型（適切な長さの VARCHAR 等）に変換し、ISAM エラー（インデックス作成エラー）を防ぎます。
• SQL エンジン活用: 既存のテーブル定義やリレーションシップをそのまま活用できます。

必須コンポーネント

JDBC Dialect 方式を採用する場合、以下の 4つの JAR ファイル を Kafka Connect の lib フォルダに配置します。

ファイル名	分類	説明
zen-kafka-jdbc-dialect-16.10.jar	Dialect	JDBC コネクタ用の方言定義ファイル
pvjdbc2.jar	Dialect	Zen JDBC コアドライバー（※）
pvjdbc2x.jar	Dialect	JDBC 拡張機能（※）
jpscs.jarr	Library	セキュリティ・接続管理ライブラリ（※）

※ pvjdbc2.jar、pvjdbc2x.jar、jpscs.jar は、JDBC SDK for Zen/PSQL ページより入手できます。

Btrieve Native Connector について

Btrieve Native Connector は、SQL レイヤーを経由せず、Zen のカーネル（Microkernel Engine）と直接通信を行う専用コネクタです。

特徴

• SQL のオーバーヘッドがないため、非常に高速に動作します。
• 汎用 JDBC コネクタを使用せず、Actian が提供する独自のコネクタクラスを使用します。

必須コンポーネント

Native 方式を採用する場合、SDK の plugin ディレクトリ内にある actian-zen-kafka-connect ディレクトリを配置します。

ファイル名	説明
actian-zen-kafka-connect	Btrieve 2 API を内包したオールインワン・コネクタ

SDK ダウンロード

ファイルをダウンロードするには、ファイル名をクリックしてください。

対応パッケージ	OS	ファイルダウンロード	容量	最終更新日	その他
Zen Kafka JDBC Dialect for Actian Zen v16 SP1	Windows	Zen-SDK-KafkaConnect-Plugin-16.10.051.000.zip	2.44 MB	2026/02/17	詳細は、Zip または TAR ファイルを解凍後、docs フォルダ内をご参照ください。
	Linux	Zen-SDK-ZenKafkaConnectPlugin-linux-noarch-16.10.051.000.tar.gz	2.37 MB

※ 上記に記載のない場合は、サポート終了製品（取扱終了製品含む）をご確認ください。

サンプル

ファイルをダウンロードするには、ファイル名をクリックしてください。

サンプル内容	OS	ファイルダウンロード	容量	最終更新日	その他
・Zen データを Kafka を通じて、クラウドやサーバーへ転送するデモ ・気象データを Kafka を通じて、リアルタイムに Zen DB へ転送するデモ	Linux	Zen-SDK-ZenKafkaConnect-linux-noarch-16.10.051.000.tar.gz	3.00 MB	2026/02/17	詳細は、TAR ファイル解凍後、docs フォルダ内をご参照ください。

ドキュメント

詳細は、Zip または TAR ファイルを解凍後、docs フォルダ内をご参照ください。