跳到主要内容

宝兰德 CloudMQ 集成说明

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

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

具体集成步骤如下：

  1. 采购宝兰德中间件 CloudMQ，要求：单机/集群模式

    HAP 单机或精简集群 可选择 单机模式，标准或专业集群 可选择 集群模式

  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 微服务生效