金蝶天燕 ADMQ 集成说明
金蝶Apusic分布式消息中间件(简称"ADMQ") 是金蝶天燕公司是一款分布式消息中间件,具有多租户、跨集群数据复制、强一致性、高可靠、高并发等特性。
在 HAP 私有部署版本中,我们默认使用 Kafka 作为消息中间件,以提供高效的数据处理能力。然而,我们也充分考虑到信创 要求,并已适配金蝶天燕公司的 ADMQ 产品。用户可以选择使用 ADMQ 来替代 Kafka。
具体集成步骤如下:
-
从金蝶天燕公司采购缓存中间件 ADMQ 并部署,支持单机、集群架构。
-
部署时,需要注意以下要求:
-
开启 KAFKA 插件
-
新增或调整下方参数为示例值
transactionCoordinatorEnabled=true
kafkaTransactionCoordinatorEnabled=true
brokerDeleteInactiveTopicsEnabled=false
defaultNumPartitions=10 -
-
部署完成后,需要手动创建一批 Topic,创建时分区数建议选择10,需要手动创建的 Topic 列表如下:
ws-word
ws-excel
ws-rowindex
ws-formulaensure
ws-exattachment
ws-largerelation
ws-slowexcel
ws-publicform
ws-editcontrols
ws-passiverelation -
部署完成后会得到 ADMQ KAFKA 服务的节点连接地址、端口、密码
-
在 HAP 微服务配置文 件中,添加如下变量,配置连接使用外部消息中间件
- 单机
- 集群
ENV_KAFKA_ENDPOINTS: "192.168.0.251:9092" # ADMQ 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" # ADMQ KAFKA 服务地址,多个使用英文逗号分隔
# 如果 HAP 私有部署版是单机模式,下面变量也可以加一下,将容器内的 Kafka 服务禁止启动
ENV_STANDALONE_DISABLE_SERVICES: "kafka" -
重启 HAP 微服务生效