21.3. Kafka メッセージを送信するカスタムタスクの追加

手順

1. Business Central 管理設定メニューで管理ユーザーとして Custom Tasks Administration を選択します。
2. KafkaPublishMessages が On に設定されていることを確認します。
3. Business Central で Menu Design Projects の順に選択し、スペース名とプロジェクト名をクリックします。
4. Settings Custom Tasks タブを選択します。
5. KafkaPublishMessages 行で Install をクリックします。

6. 必要に応じて、以下の情報を入力します。フィールドを空白のままにすると、プロセスエンジンはこれらのフィールドにデフォルト値を使用します。

   • Bootstrap Servers: Kafka ブローカーのホストおよびポート。複数の host:port ペアのコンマ区切りリストを使用できます。デフォルト値は localhost:9092 です。
   • Client ID: 要求の実行時にブローカーに渡す識別子文字列。Red Hat AMQ Streams では、この文字列を使用してロギングを行います。デフォルト値は
   • Key Serializer クラス: キーシリアライザーを提供するクラス。デフォルト値は org.apache.kafka.common.serialization.StringSerializer です。独自のカスタムシリアライザークラスを使用する場合は他の値を入力できます。

   • Value Serializer クラス: 値シリアライザーを提供するクラス。デフォルト値は org.apache.kafka.common.serialization.StringSerializer です。独自のカスタムシリアライザークラスを使用する場合は他の値を入力できます。

     これらのフィールドのいずれかで、env[property] 値を入力します。この場合、プロセスエンジンはランタイム時にシステムプロパティーから設定を読み取ります。たとえば、Client ID を env[application.client.id] に設定し、プロセスサービスを実行する前に、application.client.id システムプロパティーにクライアント ID の値を設定します。

7. カスタムシリアライザークラスの名前を入力したら、以下の追加の設定を実行します。

   1. Settings Deployments Work Item Handlers タブを選択します。

   2. KafkaPublishMessages 行で、Value フィールドを変更して classLoader パラメーターを追加します。たとえば、このフィールドの最初の値は以下の文字列になります。

      new org.jbpm.process.workitem.kafka.KafkaWorkItemHandler("127.0.0.1:9092", "jbpm", "com.myspace.test.MyCustomSerializer", "com.myspace.test.MyCustomSerializer")

      この例では、値を以下の文字列に変更します。

      new org.jbpm.process.workitem.kafka.KafkaWorkItemHandler("127.0.0.1:9092", "jbpm", "com.myspace.test.MyCustomSerializer", "com.myspace.test.MyCustomSerializer", classLoader)

8. Assets タブを選択します。
9. ビジネスプロセスを選択し、ビジネスプロセスデザイナーを開きます。
10. BPMN モデラーパレットの Custom Tasks で利用可能な KafkaPublishMessages カスタムタスクを追加します。
11. カスタムタスクのプロパティーで、データの割り当てを開きます。
12. Key、Topic、および Value 入力を割り当て、メッセージを定義します。