第22章 プロセスから Kafka メッセージを送受信するための KIE Server の設定

手順

1. Red Hat AMQ Streams との統合を有効にするには、お使いの環境に応じて以下のシステムプロパティーを設定します。

   • Red Hat JBoss EAP で KIE Server を使用している場合は、KIE Server システムプロパティー org.kie.kafka.server.ext.disabled を false に設定します。
   • Spring Boot を使用している場合は、kieserver.kafka.enabled システムプロパティーを true に設定します。
2. Kafka ブローカーへの接続を設定するには、org.kie.server.jbpm-kafka.ext.bootstrap.servers システムプロパティーをブローカーのホストおよびポートに設定します。デフォルト値は localhost:9092 です。複数の host:port ペアのコンマ区切りリストを使用できます。

3. オプション: Kafka メッセージの送信と受信の両方に関連する、次のシステムプロパティーのいずれかを設定します。

   Expand

   表22.1 Kafka メッセージの送信と受信の両方に関連するオプションの KIE Server システムプロパティー

   プロパティー	説明
   org.kie.server.jbpm-kafka.ext.client.id	リクエスト時にブローカーに渡す ID 文字列。Red Hat AMQ Streams では、この文字列を使用してロギングを行います。
   org.kie.server.jbpm-kafka.ext.topics.*	メッセージ名とトピック名のマッピング。たとえば、ExampleName がメッセージの名前で、ExampleTopic トピックでメッセージを送受信する場合は、org.kie.server.jbpm-kafka.ext.topics.ExampleName システムプロパティーを ExampleTopic に設定します。このようなシステムプロパティーはいくつでも設定できます。メッセージ名がシステムプロパティーを使用してマップされていない場合、プロセスエンジンはこの名前をトピック名として使用します。
   org.kie.server.jbpm-kafka.ext.property_name	org.kie.server.jbpm-kafka.ext 接頭辞を使用して、Red Hat AMQ Streams コンシューマーまたはプロデューサープロパティーを設定します。たとえば、buffer.memory プロデューサープロパティーの値を設定するには、KIE Server システムプロパティー org.kie.server.jbpm-kafka.ext.buffer.memory を設定します。 この設定は、この KIE Server のイベントを使用して Kafka メッセージを送受信するすべてのプロセスに適用されます。 Red Hat AMQ Streams コンシューマーおよびプロデューサープロパティーの一覧は、RHEL の AMQ Streams の使用 の付録 コンシューマー設定パラメーター および プロデューサー設定パラメーター を参照してください。

   Show more

4. オプション: Kafka メッセージの受信に関連する、次のシステムプロパティーのいずれかを設定します。

   Expand

   表22.2 オプション: Kafka メッセージの受信に関連する、オプションの KIE Server システムプロパティー

   プロパティー	説明	デフォルト値
   org.kie.server.jbpm-kafka.ext.allow.auto.create.topics	トピックの自動作成を許可する。	true
   org.kie.server.jbpm-kafka.ext.group.id	この Kafka メッセージコンシューマーが所属するグループを識別する一意の文字列。	jbpm-consumer.

   Show more

5. オプション: Kafka メッセージの送信に関連する、次のシステムプロパティーのいずれかを設定します。

   Expand

   表22.3 Kafka メッセージの送信に関連するオプションの KIE Server システムプロパティー

   プロパティー	説明	デフォルト値
   org.kie.server.jbpm-kafka.ext.acks	要求を完了としてマークする前に Kafka リーダーが受信する必要がある確認応答の数。	1.この値は、リーダーがそのローカルログにレコードを書き込み、その後、すべてのフォロワーからの完全な確認を待たずに、プロセスエンジンに応答することを意味します。
   org.kie.server.jbpm-kafka.ext.max.block.ms	publish メソッドがブロックするミリ秒数。この時間が経過すると、プロセスエンジンはビジネスプロセスの実行を再開できます。	2000 (2 秒)

   Show more