跳到主要内容

宝兰德 CloudMQ 集成说明

CloudMQ 是宝兰德公司的一款集消息、存储、轻量化函数计算为一体的云原生分布式消息流平台。

在 HAP 私有部署版本中，我们默认使用 Kafka 作为消息中间件，以提供高效的数据处理能力。然而，我们也充分考虑到信创要求，并已适配宝兰德公司的 CloudMQ 产品。用户可以选择使用 CloudMQ 来替代 Kafka。

具体集成步骤如下：

  1. 从宝兰德公司采购中间件 CloudMQ 并部署，支持单机、集群架构。

  2. 部署时，需要注意以下要求：

    • 开启 Kafka 服务

    • 配置计算实例允许自动创建主题

    • 修改计算实例参数，将默认分区数设置为 10：

      defaultNumPartitions=10

  3. 部署完成后会得到 CloudMQ Kafka 服务的节点连接地址、端口、密码

  4. 在 HAP 微服务配置文件中，添加如下变量，配置连接使用外部消息中间件

    ENV_KAFKA_ENDPOINTS: "192.168.0.251:9092"     # CloudMQ Kafka 服务地址

    # 如果 HAP 私有部署版是单机模式，下面变量也可以加一下，将容器内的 Kafka 服务禁止启动
    ENV_STANDALONE_DISABLE_SERVICES: "kafka"

  5. 重启 HAP 微服务生效