功能与技术规格

# 前言

本文档为金蝶Apusic分布式消息队列for Kafka（Apusic Distributed Message Queue，简称：ADMQ for Kafka）的功能规格说明，帮助用户详细了解ADMQ for Kafka的产品功能与技术指标。

# 适用对象

本文档适用于IT信息化业务负责人、研发经理、软件项目经理、软件架构师、运维工程师。

# 相关文档

了解更多ADMQ for Kafka产品相关的信息，请参阅以下ADMQ for Kafka产品手册文档集：

序号 手册文档 说明
1 金蝶Apusic分布式消息队列for Kafka 快速使用手册 简单介绍了如何快速上手使用ADMQ for Kafka 。
2 金蝶Apusic分布式消息队列for Kafka 安装手册 详细介绍如何在各操作系统上安装ADMQ for Kafka，以及ADMQ for Kafka服务启停等操作。
3 金蝶Apusic分布式消息队列for Kafka 消息引擎用户手册 详细介绍 ADMQ for Kafka 消息引擎相关功能的使用、配置、管理及配套工具的使用方法。
4 金蝶Apusic分布式消息队列for Kafka 管控台用户手册 详细介绍ADMQ for Kafka管控台相关功能的使用和操作说明。
5 金蝶Apusic分布式消息队列for Kafka 开发手册 详细介绍基于各开发语言进行ADMQ for Kafka客户端应用开发的说明。
6 金蝶Apusic分布式消息队列for Kafka 迁移手册 详细介绍从Kafka迁移到ADMQ for Kafka的说明。
7 金蝶Apusic分布式消息队列for Kafka 运维手册 详细介绍ADMQ for Kafka的监控、运维、安全加固等运维说明。
8 金蝶Apusic分布式消息队列for Kafka 性能优化手册 详细介绍ADMQ for Kafka性能调优的说明。

# 技术支持

ADMQ for Kafka产品提供全面的技术支持服务，您可以通过以下方式获得技术支持：

  • 网址：www.apusic.com
  • 电话：400-855-5800
  • 邮箱：support@apusic.com
  • 金蝶云社区：https://vip.kingdee.com/?productId=73&productLineId=14&lang=zh-CN

您在取得技术支持时，请提供如下信息：

  1. 您的姓名

  2. 公司信息与联系方式

  3. 操作系统及其版本

  4. 产品版本号

  5. 出现异常及错误的日志、截图等详细信息

# 产品版本与兼容性

# 版本信息

属性 说明
产品名称 金蝶Apusic分布式消息队列
产品版本 ADMQ for Kafka V2.0.6.391
发布日期 2026年3月

# 客户端兼容性

ADMQ for Kafka V2.0.6.391 兼容以下Kafka客户端版本：

客户端类型 支持版本 说明
Java 2.8.x - 3.9.x 支持所有现代 Java 客户端
Go 0.10.x - 1.x 官方 Go 客户端
Python 1.x - 2.x 官方 Python 客户端
C/C++ 1.x - 2.x librdkafka 客户端
.NET 1.x - 3.x 官方 .NET 客户端
Node.js 1.x - 3.x 官方 Node.js 客户端

# 协议兼容性

协议 状态 说明
PLAINTEXT 支持 明文传输协议
SSL 支持 SSL 加密传输
SASL_PLAINTEXT 支持 SASL 明文认证
SASL_SSL 支持 SASL SSL 认证
SCRAM-SHA-256 支持 SCRAM SHA-256 认证
SCRAM-SHA-512 支持 SCRAM SHA-512 认证
OAuthBearer 支持 OAuth2 认证

# 核心功能特性

# 消息收发

功能 说明 状态
生产者（Producer） 支持同步/异步发送、批量发送、压缩 支持
消费者（Consumer） 支持拉取模式、批量消费、消费者组 支持
消息顺序 单分区有序，支持 Key 分区策略 支持
消息持久化 消息持久化到磁盘，支持多副本 支持
消息压缩 支持 GZIP、SNAPPY、LZ4、ZSTD 支持
幂等性 精确一次语义（Exactly-Once） 支持
事务 支持多分区原子写入 支持

# 主题与分区

功能 说明 状态
Topic 创建/删除 支持手动创建、自动创建 支持
分区管理 支持增加分区（不可减少） 支持
分区副本 支持配置副本数及副本分配 支持
分区重分配 支持手动触发副本迁移 支持
日志压缩 支持 Log Compaction 清理策略 支持
日志保留 支持时间/大小保留策略 支持

# 消费者组

功能 说明 状态
消费者组 支持消费者组管理 支持
Rebalance 支持自动 Rebalance 策略 支持
Offset 管理 支持自动/手动提交 Offset 支持
Offset 重置 支持重置到最早/最新/指定位置 支持
消费进度 支持查看消费延迟（Lag） 支持

# 高可用与容错

功能 说明 状态
多副本 支持配置多副本冗余 支持
ISR 机制 支持 In-Sync Replicas 同步 支持
Leader 选举 支持自动 Leader 选举 支持
故障恢复 支持自动故障转移 支持
控制器（Controller） 支持 Controller 选举和管理 支持
副本同步 支持快速副本同步 支持

# 安全特性

功能 说明 状态
身份认证 支持 SASL/PLAIN/SCRAM 认证 支持
授权管理 支持 ACL 访问控制 支持
传输加密 支持 SSL/TLS 加密 支持
角色控制 支持 RBAC 角色管理 支持
多租户 支持资源隔离和多租户 支持

# 运维管理

功能 说明 状态
监控指标 支持 JMX/Prometheus 指标导出 支持
日志管理 支持日志级别配置和日志轮转 支持
配置管理 支持动态配置更新 支持
集群管理 支持节点添加/移除 支持
配额管理 支持生产/消费配额控制 支持

# 技术规格

# 系统要求

组件 最低要求 推荐配置
CPU 4 核 8 核及以上
内存 8 GB 16 GB 及以上
磁盘 100 GB SSD 500 GB 及以上 SSD
网络 1 Gbps 10 Gbps
操作系统 Linux (CentOS 7+, Ubuntu 18.04+, 麒麟, 统信) -

# 集群规模

部署模式 Broker 数量 说明
单机 1 开发测试环境
集群 3-5 生产环境最小配置
大规模 10+ 高吞吐场景

# 性能指标

指标 单节点 3节点集群 说明
吞吐量 10万/秒 50万/秒 生产者发送速率
延迟 5ms 3ms P99 延迟
副本同步 <1s <1s 副本同步延迟
故障恢复 <30s <30s Leader 切换时间

# 网络端口

端口 用途 说明
9092 Broker 生产者和消费者连接
9093 SSL 加密 SSL 协议连接
2181 ADCC ADCC客户端连接
9094 SASL 认证 SASL 认证连接
12305 管控台 HTTP 管控台 Web 界面（HTTP）
12306 管控台 HTTPS 管控台 Web 界面（HTTPS）

# 支持的存储

类型 支持情况 说明
EXT4 支持 Linux 标准文件系统
XFS 推荐 高性能文件系统
NFS 支持 网络文件系统（需配置）
多盘挂载 支持 支持多数据目录

# 部署模式

部署模式 Broker数量 说明
单机模式 1 适用于开发测试环境，内置 ADCC for zk，无高可用保障
集群模式 3-10+ 适用于生产环境，支持高可用保障和横向扩展
混合部署 3+ 支持 ADCC for zk 和 Broker 混合部署，降低部署成本

# 备份与容灾

# 数据备份

备份方式 说明
副本备份 通过多副本机制实现数据冗余
定期备份 支持定期导出Topic数据
跨机房备份 支持MirrorMaker跨机房同步

# 容灾能力

容灾级别 能力
节点故障 自动故障转移，保证服务连续性
磁盘故障 多副本机制，单盘故障不影响服务
机房级 支持跨机房多活部署
数据安全 支持定期快照备份
编辑页面 (opens new window)
#功能与技术规格

← 安装手册→