第14章 Red Hat Decision Manager Red Hat ビルドの Kogito Operator と Kafka との対話

Red Hat Decision Manager Red Hat ビルドの Kogito Operator は、AMQ Streams Operator を使用して、Kafka を使用する Kogito マイクロサービスの Red Hat ビルドを自動的に設定します。

KogitoInfra デプロイメントを通じてインフラストラクチャーメカニズムを有効にすると、Kogito Operator の Red Hat Decision Manager Red Hat ビルドは、関連するサードパーティー Operator を使用してインフラストラクチャーを設定します。

カスタムインフラストラクチャーリソースを定義し、それを KogitoInfra ファイルにリンクする必要があります。カスタムインフラストラクチャーリソースは、spec.resource.name および spec.resource.namespace 設定で指定できます。

apiVersion: rhpam.kiegroup.org/v1 # Red Hat build of Kogito API for this microservice
kind: KogitoInfra # Application type
metadata:
  name: my-kafka-infra
spec:
  resource:
    apiVersion: kafka.strimzi.io/v1beta2 # AMQ Streams API
    kind: Kafka	# AMQ Streams Application Type
    name: my-kafka-instance
    namespace: my-namespace

この例では、KogitoInfra カスタムリソースは、イベントメッセージングのために my-namespace から Kafka クラスター my-kafka-instance に接続します。

Red Hat ビルドの Kogito マイクロサービスを Kafka に接続するには、対応するインフラストラクチャーを使用するための infra 設定を定義する必要があります。

apiVersion: rhpam.kiegroup.org/v1 # Red Hat build of Kogito API for this microservice
kind: KogitoRuntime # Application type
metadata:
  name: example-quarkus # Application name
spec:
  image: <final-image-name> # Kogito image name
  insecureImageRegistry: true # Can be omitted when image is pushed into secured registry with valid certificate
  infra:
  - my-kafka-infra

Red Hat Decision Manager Red Hat ビルドの Kogito Operator は、アプリケーションが Kafka インスタンスに接続できるように必要なプロパティーを設定します。