管控台用户手册
# 前言
本文档为金蝶 Apusic 分布式消息队列 for Kafka（Apusic Distributed Message Queue，简称：ADMQ for Kafka）管控台产品的用户手册，详细介绍 ADMQ for Kafka 产品 Web 管控台的功能使用、配置方法及管理操作等内容。
# 适用对象
本文档适用于 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
您在取得技术支持时，请提供如下信息：
- 您的姓名
- 公司信息与联系方式
- 操作系统及其版本
- 产品版本号
- 出现异常及错误的日志、截图等详细信息
# 版本变更说明
| 版本 | 日期 | 变更说明 |
|---|---|---|
| V2.0.6 | 2026-06-23 | 新增 ADMQ for Kafka 管控台用户手册，涵盖管理面入口、主题管理、订阅组管理、用户与 ACL 管理、消息查询、监控与统计、常见问题及附录等内容。 |
# 概述
金蝶 Apusic 分布式消息队列 for Kafka（Apusic Distributed Message Queue，简称：ADMQ for Kafka）管控台是面向 ADMQ for Kafka 集群的 Web 管理界面，分为系统管理与运维管理两侧。
- 系统管理侧：主要用于核心引擎的接入、集群配置、用户管理及权限配置。管理员需先在系统管理侧完成 Kafka 服务节点（Broker）集群的接入与对接。
- 运维管理侧：用于日常集群运维，包括主题、订阅组、用户、ACL、消息查询及监控统计等操作。接入完成后，运维人员可登录运维管理侧查看引擎状态并进行管理维护。
用户需先进入系统管理侧进行集群配置与对接，然后在运维管理侧进行集群管理。
# 安装和运行
# 运行环境
ADMQ for Kafka 管控台基于 Java Web 技术构建，运行前请确认已满足以下环境要求：
| 项目 | 要求 |
|---|---|
| JDK | JDK 1.8 及以上 |
| CPU | 建议 2 核及以上 |
| 内存 | 建议 4 GB 及以上 |
| 磁盘 | 根据消息保留策略与集群规模预留足够空间 |
| 浏览器 | 推荐 Chrome、Firefox、Edge 等主流浏览器的最新版本 |
| 网络 | 管控台服务器需能访问 Kafka 集群的 JMX 端口及管理端口 |
关于 ADMQ for Kafka 管控台的完整安装、启动、停止及升级步骤，请参阅《金蝶 Apusic 分布式消息队列 for Kafka 安装手册》。
# 管理面入口
# 访问地址
在浏览器地址栏输入以下 URL 进入 ADMQ 管控台登录页面：
http://{console_ip}:12305
其中 {console_ip} 为管控台服务器 IP 地址。
# 登录流程
第 1 步： 打开浏览器，输入上述访问地址，进入登录页面。
第 2 步： 输入默认账号与密码。系统首次安装后，默认管理员账号为 admq。
第 3 步： 首次登录时，系统会强制要求修改初始密码。请按页面提示设置复杂度符合要求的新密码，并妥善保存。
第 4 步： 登录成功后，根据账号权限进入系统管理侧或运维管理侧。
安全注意事项：首次登录后请立即修改默认密码，避免使用弱密码；生产环境建议为不同角色分配最小必要权限，并定期审计 ACL 规则与用户权限。
# 默认账号与权限
| 账号 | 初始密码 | 所属角色 | 权限说明 |
|---|---|---|---|
| admq | admq（首次登录需修改） | 系统管理员 | 拥有系统管理侧与运维管理侧的完整权限，可进行集群接入、用户管理、ACL 配置及所有运维操作 |
普通用户账号由管理员在【用户管理】中创建，权限通过 ACL 规则进行细粒度控制。
# 界面布局简介
登录后，管控台界面分为左右两侧：
- 系统管理侧：左侧导航包含集群管理、用户管理、ACL 管理等，用于引擎接入、集群配置、权限与安全设置。
- 运维管理侧：左侧导航包含资源管理（主题、订阅组）、消息查询、监控运维（监控大盘、消息统计报表）等，用于日常集群运维与监控。
页面顶部通常包含集群选择器、全局搜索及个人中心等通用入口。
# 主题管理
# 功能入口
【资源管理】-【主题】
# 查看主题列表
支持按以下条件筛选：
- 主题类型：普通主题 / 系统主题
- 名称：按主题名称模糊搜索
列表字段说明：
| 字段 | 说明 |
|---|---|
| 名称 | 主题名称，点击可进入详情页，支持一键复制 |
| 类型 | 普通主题 / 系统主题 |
| 分区数 | 该主题的分区数量 |
| 不同步副本数 | 当前副本未完全同步的分区数量（大于 0 表示存在可用性风险） |
| 副本数 | 每个分区的副本数量 |
| 消息数量 | 主题下所有分区的消息总数 |
| 存储占用 | 主题消息占用的磁盘空间大小 |
| 描述 | 描述信息 |
# 创建主题
点击列表右上角的 "新增" 按钮，打开主题新建页面：
在 基本配置 区域填写：
配置项 必填 说明 主题名称 是 只能包含英文、数字、 _、-、.，长度不超过 128 字符分区数量 是 正整数，建议根据并发量设置，至少 1。默认值为 6 分区副本数 是 选择集群默认或自定义数量（1 ~ Broker 数量，建议 ≥ 2） 消息保留时间 是 消息在主题中的保留时长，单位毫秒。快捷选项：1小时、8小时、24小时、7天（默认）、30天 最大存储大小 是 主题消息占用的最大磁盘空间限制。默认"不限制"（-1 GB） 清理策略 是 单选：删除（默认）/ 压缩 / 压缩&删除 主题备注 否 描述信息，最多 160 字符 在 常用参数 区域可选配置：
参数 默认值 说明 消息时间戳类型 (message.timestamp.type) CreateTime 消息时间戳的生成方式 是否允许从非同步副本选举 (unclean.leader.election.enable) false 是否允许不在同步副本集合（In-Sync Replicas，ISR）中的副本成为主副本（Leader） 日志段滚动时间间隔 (segment.ms) 引擎默认值 日志段按时间滚动的间隔 单条消息最大允许大小 (max.message.bytes) 引擎默认值 单条消息的最大字节数 在 自定义参数 区域，有经验的运维人员可添加和修改高级参数：
⚠️ 自定义参数仅限于有经验的运维人员添加和修改。默认配置参数优先于自定义参数。
点击右下角 "确定" 保存，或点击 "取消" 放弃。
注意事项：
- 分区数创建后只能增加，不能减少。
- 副本因子创建后不可修改。
- 系统内部主题（如
__consumer_offsets）不允许修改。
# 发送消息
点击行末的 "发送消息" 按钮，可向指定主题发送测试消息：
- Key：消息的键，用于分区路由（相同 Key 的消息会进入同一分区）
- Value：消息内容
- 选择分区：可选，指定发送到哪个分区；不指定时按 Key 的哈希路由
- Headers：可选，用于存放和消息内容无关的元数据
此功能常用于调试和验证主题是否正常工作。
# 复制主题
点击行末的 "复制" 按钮，可基于已有主题的配置快速创建新主题：
- 系统会自动填充原主题的分区数、副本因子等配置
- 只需修改名称即可快速创建
# 编辑主题
点击行末的 "编辑" 按钮，可修改主题描述信息。
主题名称、分区数（不支持减少）、副本因子创建后不可修改。
# 删除主题
点击行末的 "删除" 按钮，确认后删除。删除主题将同时删除该主题下的所有消息，请谨慎操作。
系统内部主题不可删除。
# 清空主题
点击行末的 "清空" 按钮，将删除该主题所有分区中的消息。此操作不可恢复，请谨慎使用。
# 批量操作
通过列表左侧的复选框选择多个主题后，可进行批量操作：
- 批量删除：同时删除选中的多个主题
- 批量重平衡：同时进行多个主题重平衡
# 同步主题
点击 "同步" 按钮，可将 Kafka 集群中实际存在的主题与平台数据库进行比对和同步：
- 系统将展示差异预览：新增（集群有但平台无）、删除（平台有但集群无）、更新（双方存在差异）
- 勾选需要同步的项目，点击 "确认同步"
建议在集群有变更（如通过其他工具创建了主题）后执行同步，确保平台数据与集群一致。
# 主题详情
点击主题名称，进入详情页，可查看该主题的详细信息：
# 分区信息
展示各分区的基本信息：
- 分区 ID
- Leader 副本所在 Broker
- ISR（同步副本列表）
- 起始偏移量 / 最新偏移量
- 消息数量
# 消息列表
展示该主题各分区中的消息，支持按分区筛选，可查看消息的 Key、Value、偏移量、时间戳等信息。
# 配置信息
展示主题的详细配置参数，如清理策略（delete/compact）、保留时间、段大小等。
# 订阅信息
展示消费该主题的订阅组列表及各消费组的消费进度（每个分区的当前偏移量）。
# 扩容分区
当主题的消息量增加，需要提升并行消费能力时，可以对主题进行扩容：
- 在主题列表中，点击行末的 "扩容" 按钮
- 输入新的分区数（必须大于当前分区数）
- 点击 "确认"
扩容后，已有的消息不会重新分布到新分区，只有新消息会按新的分区数路由。
# 订阅组管理
# 功能入口
【资源管理】-【订阅组】
# 查看订阅组列表
支持按名称模糊搜索。列表字段说明：
| 字段 | 说明 |
|---|---|
| 名称 | 订阅组名称，点击可进入详情页，支持一键复制 |
| 描述 | 描述信息 |
| 成员数 | 当前在线的消费者实例数量 |
| 订阅主题数 | 该组订阅的主题数量 |
| 消费延迟数 | 该组累计的消费延迟（Lag）总数，即未消费消息数 |
| 所属节点 | 该订阅组的协调器（Coordinator）所在 Broker 节点 |
| 状态 | 消费中 / 准备重平衡 / 正在重平衡 / 失效 / 空闲 |
# 状态说明
| 状态 | 说明 |
|---|---|
| 消费中（Stable） | 消费者正常消费消息 |
| 准备重平衡（PreparingRebalance） | 有消费者加入或离开，正在准备重新分配分区 |
| 正在重平衡（CompletingRebalance） | 分区分配方案已确定，正在完成重平衡 |
| 失效（Dead） | 订阅组已失效，无活跃消费者 |
| 空闲（Empty） | 订阅组存在但当前无消费者 |
# 创建订阅组
- 点击列表右上角的 "新增" 按钮
- 填写表单：
- 名称（必填）：订阅组唯一标识，创建后不可修改
- 描述（可选）
- 点击 "确认" 保存
订阅组名称创建后不可修改。
# 编辑订阅组
点击行末的 "编辑" 按钮，可修改订阅组的描述信息。
# 删除订阅组
点击行末的 "删除" 按钮，确认后删除。删除订阅组将清除该组的偏移量记录，请谨慎操作。
# 同步订阅组
点击 "同步" 按钮，可将 Kafka 集群中实际存在的订阅组与平台数据库进行比对和同步。
# 订阅组详情
点击订阅组名称，进入详情页，可查看该订阅组的详细信息：
# 订阅信息
展示该组订阅的所有主题及各主题在各分区的消费进度。
# 消费者列表
展示当前在线的消费者实例：
- 分区名称
- 消费者名称
- 地址
- 消息延迟
- 当前偏移量
- 最新偏移量
# 重置偏移量
当需要重新消费历史消息或跳过部分消息时，可以重置订阅组的消费偏移量：
在订阅组列表中，点击行末的 "重置偏移量" 按钮。
选择重置策略：
- 重置到最早：消费位点回到各分区的最早消息
- 重置到最新：消费位点跳到各分区的最新消息
- 重置到指定时间：消费位点回到指定时间戳对应的位置
选择分区
点击 "确认"
重置偏移量会影响所有正在运行的消费者，请确保业务可接受重复消费或消息丢失。
# 用户管理
# 功能入口
【用户】-【用户管理】
# 查看用户列表
列表字段说明：
| 字段 | 说明 |
|---|---|
| 用户名 | 用户标识 |
| 认证方式 | SCRAM-SHA-256 / SCRAM-SHA-512 等 |
| 描述 | 描述信息 |
| 状态 | 正常 / 已删除 |
# 创建用户
点击列表右上角的 "新增" 按钮
填写表单：
- 用户名（必填）：用户唯一标识，创建后不可修改
- 密码（必填）：至少 6 位字符
- 描述（可选）
点击 "确认" 保存
# 编辑用户
点击行末的 "编辑" 按钮，可修改用户密码和描述信息。
用户名创建后不可修改。
# 删除用户
点击行末的 "删除" 按钮，确认后删除。删除用户后，使用该用户认证的客户端连接将被断开。
# 同步用户
点击 "同步" 按钮，可将 Kafka 集群中实际存在的用户与平台数据库进行比对和同步。
同步逻辑与主题/订阅组同步相同，用于解决平台数据与集群实际状态不一致的问题。
# ACL 管理
# 功能入口
【用户】-【ACL管理】
# 查看 ACL 列表
列表字段说明：
| 字段 | 说明 |
|---|---|
| 资源类型 | Topic / Group / Cluster / TransactionalId / DelegationToken |
| 资源名称 | 具体的资源标识 |
| 匹配模式 | LITERAL（精确匹配）/ PREFIXED（前缀匹配） |
| Principal | 被授权的用户，格式为 User:用户名 |
| 操作权限 | Read / Write / Create / Delete / Alter / Describe / All |
| 权限类型 | ALLOW（允许）/ DENY（拒绝） |
| Host | 允许访问的来源主机，* 表示所有主机 |
# 创建 ACL
- 点击列表右上角的 "新增" 按钮
- 填写表单：
- 资源类型（必填）：选择要控制的资源类型
- 资源名称（必填）：资源的具体名称
- 匹配模式（必填）：LITERAL 或 PREFIXED
- Principal（必填）：格式为
User:用户名 - 操作权限（必填）：选择允许的操作
- Host（必填）：
*表示所有主机，或指定具体 IP - 效力（必填）：ALLOW 或 DENY
- 点击 "确认" 保存
ACL 规则示例：
- 允许用户
app-producer向主题app-logs写入消息：资源类型=Topic，资源名称=app-logs，Principal=User:app-producer，操作权限=Write，效力=ALLOW- 拒绝用户
test-user访问所有主题：资源类型=Topic，资源名称=*，匹配模式=PREFIXED，Principal=User:test-user，操作权限=All，效力=DENY
安全提示：请遵循最小权限原则，仅为用户分配完成任务所需的最小权限集合，并优先使用精确匹配（LITERAL）而非前缀匹配（PREFIXED），以降低误授权风险。
# 编辑 ACL
点击行末的 "编辑" 按钮，可修改 ACL 规则的所有字段。
# 删除 ACL
点击行末的 "删除" 按钮，确认后删除该 ACL 规则。
# 同步 ACL
点击 "同步" 按钮，可将 Kafka 集群中实际存在的 ACL 规则与平台数据库进行比对和同步。
建议在进行权限变更或排查权限问题时执行同步。
# 消息查询
# 功能入口
【消息查询】-【消息查询】
# 查询消息
- 选择要查询的主题
- （可选）选择具体的分区，不选则查询该主题的所有分区
- 设置查询条件：
- 偏移量范围：按起始偏移量和结束偏移量筛选
- 时间范围：按消息时间戳筛选
- Key 过滤：按消息 Key 模糊匹配
- 点击 "查询" 按钮
查询结果列表字段说明：
| 字段 | 说明 |
|---|---|
| 偏移量 | 消息在分区中的偏移量 |
| 所属分区 | 消息所在的分区 ID |
| 消息时间 | 消息的时间戳 |
| Key | 消息的键 |
| Value | 消息的内容（长度限制显示） |
# 查看消息详情
点击行末的 "查看消息" 按钮，可查看消息的完整内容，包括：
- 主题、消息大小、时间戳
- Key 和 Value 的完整内容
- 消息头（Headers）信息
# 导出消息
点击行末的 "导出" 按钮，可将单条消息导出为文件。
批量导出功能可通过消息统计报表模块实现。
# 使用建议
- 消息查询功能主要用于排查问题和验证消息内容，不建议作为常规的数据消费方式。
- 查询大量消息时，建议缩小时间范围或指定具体分区，以提高查询效率。
- 消息的 Value 可能经过序列化（如 JSON、Avro、Protobuf），查看时请注意格式转换。
# 监控与统计
# 监控大盘
# 功能入口
【监控运维】-【监控大盘】
# 时间范围选择
页面顶部提供时间范围选择器，支持快捷选项（最近1小时、最近6小时、最近1天等）和自定义时间范围。
# 监控维度
监控大盘分为四个标签页：
# 集群
展示集群整体运行状况，包括：
- Broker（在线/总数）：当前在线 Broker 数量和总 Broker 数量
- 主题数：集群中 Topic 总数
- 分区数：集群中 Partition 总数
- 消息流入速率：集群整体消息生产速率（条/秒）
- 消息吞吐量趋势图：生产/消费速率随时间变化曲线
# 节点
展示各节点的资源使用情况：
- 节点列表：分区数、Leader 数、日志目录大小、JVM 内存使用/上限、CPU 使用率、连接数
- 选中节点后展示趋势图：消息速率、字节流入/流出速率、请求速率等
# 主题
展示主题相关的监控指标（需选择具体主题）：
- 消息生产速率（条/秒）
- 字节流入速率（字节/秒）
- 字节流出速率（字节/秒）
- 存储大小（字节）
- 消息总量（条）
- 分区数（个）
- 副本不足分区数（个）
# 订阅组
展示订阅组相关的监控指标（需选择具体订阅组）：
- 消息消费速率（条/秒）
- 消息堆积数量（条）
- 按 Topic 堆积（条）
- 消费者成员数（个）
监控数据来源于 Kafka Java 管理扩展（Java Management Extensions，JMX）指标，数据刷新频率约为 5 秒。
# 消息统计报表
# 功能入口
【监控运维】-【消息统计报表】
# 查看统计结果
支持两种统计维度：
- 集群维度：按日期聚合整个集群的消息指标
- Topic 维度：按日期 + Topic 聚合消息指标
统计指标包括：
| 指标 | 说明 |
|---|---|
| 生产消息数 | 生产者发布到集群/Topic 的消息数量 |
| 消费消息数 | 消费者从集群/Topic 消费的消息数量 |
| 入站字节数 | 流入集群的总字节数 |
| 出站字节数 | 流出集群的总字节数 |
# 导出报表
点击 "导出" 按钮，可将当前查询结果导出为 Excel 文件。
# 统计任务
如需按固定周期（如每小时、每天）自动统计消息数据，请联系管理员配置定时统计任务。
# 常见问题
# Q1: 为什么创建了主题但在列表中看不到？
可能原因：
- 集群选择器 —— 检查是否选择了正确的 Kafka 集群
- 数据未同步 —— 如果通过其他工具直接创建了主题，需点击 "同步" 按钮将数据同步到平台
- 筛选条件 —— 检查是否设置了主题类型等筛选条件
# Q2: 消费者消费速度慢，消息堆积严重怎么办？
- 进入 监控大盘 → 订阅组，查看该消费组的 Lag 趋势
- 检查消费者实例数量是否足够，考虑增加消费者实例
- 如果消费者数已达到分区数上限，考虑对主题进行扩容（增加分区数）
- 检查消费者代码是否存在性能瓶颈（如单条消息处理时间过长）
# Q3: 如何查看某个订阅组的消费进度？
- 进入 订阅组 页面
- 点击订阅组名称进入详情页
- 在"订阅信息"标签页中，查看各分区当前的消费偏移量与最新偏移量的对比
# Q4: 发送消息时如何选择分区？
- 不指定分区 + 有 Key：按 Key 的哈希值路由到对应分区（相同 Key 的消息进入同一分区）
- 不指定分区 + 无 Key：按轮询策略分配分区
- 指定分区：消息直接进入指定分区
# Q5: 同步按钮的作用是什么？
同步功能用于解决平台数据与 Kafka 集群实际状态不一致的问题。场景包括：
- 通过 Kafka 命令行工具或其他管理界面直接操作了集群资源
- 集群发生故障恢复后数据不一致
- 首次接入已有数据的集群
同步会比对平台数据库和集群实际状态，展示差异并支持选择性同步。
# Q6: 主题的分区数可以缩减吗？
不可以。Kafka 的分区数只能增加，不能减少。这是 Kafka 的设计限制，因为减少分区会导致已有消息的归属混乱。
如果分区数设置过多，建议创建新主题并迁移数据。
# Q7: ACL 规则的优先级是怎样的？
Kafka ACL 的匹配优先级如下：
- 精确匹配优先于前缀匹配（LITERAL > PREFIXED）
- DENY 优先于 ALLOW
建议遵循最小权限原则，仅为用户分配必要的权限。
# 附录
# 术语表
| 术语 | 说明 |
|---|---|
| Topic（主题） | Kafka 中消息的逻辑分类单元，生产者发送消息到指定主题，消费者从主题订阅消息 |
| Partition（分区） | 主题的物理分片，一个主题可包含多个分区，分区是 Kafka 并行处理的基本单位 |
| Broker（Kafka 服务节点） | Kafka 集群中的单个服务节点，负责接收、存储和转发消息 |
| ISR（In-Sync Replicas，同步副本集合） | 与主副本保持同步的副本集合，只有 ISR 中的副本才有资格被选为主副本 |
| Leader（主副本） | 分区的主副本，负责处理该分区的所有读写请求 |
| Consumer Group（消费组） | 一组共同消费一个或多个主题的消费者实例，组内消费者协调分配分区 |
| Offset（偏移量） | 消息在分区中的唯一标识，消费者通过偏移量记录消费位置 |
| JMX（Java Management Extensions，Java 管理扩展） | Java 平台标准监控与管理接口，ADMQ for Kafka 通过 JMX 暴露运行指标 |
| ACL（Access Control List，访问控制列表） | Kafka 的权限控制机制，用于限制用户或客户端对资源的操作权限 |
| Rebalance（重平衡） | 消费组成员发生变化时，重新分配分区的过程 |
| Lag（消费延迟） | 消费者当前偏移量与分区最新偏移量之间的差值，表示未消费消息数 |
# 配置参考表
| 参数/配置项 | 默认值 | 说明 |
|---|---|---|
num.partitions | 6 | 主题默认分区数 |
default.replication.factor | 1 | 主题默认副本数 |
retention.ms | 604800000（7 天） | 消息保留时长，单位为毫秒 |
log.retention.bytes | -1 | 日志保留最大字节数，-1 表示不限制 |
cleanup.policy | delete | 日志清理策略，可选 delete / compact / compact&delete |
max.message.bytes | 1000012 | 单条消息最大允许字节数 |
message.timestamp.type | CreateTime | 消息时间戳类型，可选 CreateTime / LogAppendTime |
unclean.leader.election.enable | false | 是否允许非 ISR 副本选举为 Leader |
segment.ms | 604800000（7 天） | 日志段按时间滚动的间隔 |
min.insync.replicas | 1 | 生产者请求成功所需的最小 ISR 数量 |