宝兰德 CloudMQ 統合ガイド

CloudMQ は、宝兰德社が提供する、メッセージング・ストレージ・軽量関数実行を統合したクラウドネイティブ分散型メッセージストリーミングプラットフォームです。

HAP のオンプレミス版では、デフォルトでメッセージミドルウェアとして Kafka を採用しており、高速なデータ処理能力を提供します。一方、信創要件に配慮し、宝兰德社 CloudMQ 製品にも対応済みです。ユーザーは、Kafka の代わりとして CloudMQ を選択できます。

統合手順は以下の通りです。

宝兰德社製 CloudMQ を調達してください。単一ノードモードまたはクラスターモードを選択します。

HAP の単一ノードまたはコンパクトクラスター構成では単一ノードモードを、標準またはプロフェッショナルクラスター構成ではクラスターモードを選択できます。
デプロイ時には、以下の点に注意してください。
- Kafka サービスを有効にします。
- 計算インスタンスでトピックの自動作成を許可します。
- 計算インスタンスのデフォルトのパーティション数を 10 に設定します。
```
defaultNumPartitions=10
```
デプロイ後、CloudMQ Kafka サービスのノード接続アドレス、ポート、パスワードを取得します。

HAP マイクロサービスの設定ファイルに以下の変数を追加し、外部メッセージミドルウェアへの接続を設定します。

単一ノード
クラスター

ENV_KAFKA_ENDPOINTS: "192.168.0.251:9092"     # CloudMQ Kafka サービスアドレス

# HAP 単一ノードモードでは、以下の環境変数でコンテナ内のデフォルト Kafka サービスの起動を無効化できます
ENV_STANDALONE_DISABLE_SERVICES: "kafka"

ENV_KAFKA_ENDPOINTS: "192.168.0.251:9092,192.168.0.178:9092,192.168.0.222:9092"   # CloudMQ Kafka サービスアドレス（複数はカンマ区切り）

# HAP 単一ノードモードでは、以下の環境変数でコンテナ内のデフォルト Kafka サービスの起動を無効化できます
ENV_STANDALONE_DISABLE_SERVICES: "kafka"

HAP マイクロサービスを再起動し、設定を反映します。