CDC Replication Engine for Kafkaと連動するカスタム Java アプリケーションに、トランザクション整合コンシューマーを組み込むことができます。
このタスクについて
CDC Replication Engine for Kafka で提供されているトランザクション整合コンシューマー・アプリケーションを、ニーズに合わせて変更することも、カスタム・アプリケーションを作成するためのサンプルとして使用することもできます。
手順
- txnconsumer-applications-samples-*-sources.jar ファイルを CDC Replication Engine for Kafka インストール・ディレクトリーの /lib ディレクトリーに解凍します。
cd CDC_Kafka_installation_directory/lib
cat txnconsumer-applications-samples-*-sources.jar | jar -xv
- CDC_Kafka_installation_directory/lib/com/datamirror/ts/kafka/ でトランザクション整合性のあるサンプル・コンシューマー・アプリケーションを見つけ、サンプルとして使用するアプリケーションを見つけます。
- サンプル・クラスと .java ファイルの名前を変更して、既存のサンプル .java ファイルとは異なる名前にします。
- .java ファイルを変更します。
- ユーザー定義の .java ファイルをコンパイルします。
javac -classpath "CDC_Kafka_installation_directory/lib/*" CDC_Kafka_installation_directory/lib/com/datamirror/ts/kafka/txconsistentconsumer/sampleapplications/user-defined-application.java
- ユーザー定義の .java ファイルがあるディレクトリーに .class ファイルが作成されたことを確認します。
ls CDC_Kafka_installation_directory/lib/com/datamirror/ts/kafka/txconsistentconsumer/sampleapplications
注: クラスのコンパイルから生成するファイルは、CLASSPATH 環境変数によって参照されるライブラリーまたはフォルダー内になければなりません。
- CDC Replication Engine for Kafka インストール・ディレクトリーの /lib ディレクトリーからアプリケーションを呼び出します。
cd CDC_Kafka_installation_directory/lib
java -cp "*" com.datamirror.ts.kafka.txconsistentconsumer.sampleapplications.application name -cs commit stream topic name -c consumer configuration file name
注: CDC Replication Engine for Kafka で提供されるライブラリーと競合するライブラリーを CLASSPATH に追加することはサポートされていません。