SwimmingLiu opened a new pull request, #235: URL: https://github.com/apache/eventmesh-dashboard/pull/235
通过 Kafka AdminClient 和节点 JMX 采集集群、Broker、Topic、分区及消费组指标，新增八类报表模型，接入现有采集和 IoTDB 存储流程，并修复采集结果交付及报表查询问题。 已完成的指标采集： - [x] 集群 Broker、业务 Topic、分区、离线分区和消费组数量。 - [x] Topic 分区数、副本总数、ISR 不足分区数和离线分区数。 - [x] 分区最早保留位点和日志末端位点。 - [x] 消费组成员数，以及消费组、Topic、分区维度的提交位点、末端位点和 Lag。 - [x] Broker 累计消息数、收发字节数、生产及拉取请求数、失败请求数、拒绝字节数和副本复制流量。 - [x] Broker 与 Topic 维度的累计消息数和收发字节数。 - [x] Broker 分区、副本和 ISR 状态，以及日志大小和 Produce/Fetch 等待队列大小。 - [x] 请求处理线程空闲比例，以及 Produce/Fetch 请求的平均和 P99 延迟。 采集处理： - 每个集群注册一个 Admin 采集任务，每个已配置 JMX 端口的 Broker 注册一个 JMX 任务。 - 保留组织、集群、Broker、Topic、消费组、分区和采样时间维度；缺失指标保存为 NULL。 - Counter 读取 JMX 的 Count 属性，保存累计值；集群和 Topic 元数据统计排除内部 Topic。 - 启动时加载采集配置，之后每 5 秒刷新；修复采集轮次计数、并发结果合并和乱序结果交付问题。 - 修复单报表结果键不一致、批量查询对象未赋值及查询 SQL 错误，保留 Kafka 标签和聚合维度，并绑定时间及资源 ID 参数。 验证： - 补充 7 个单元测试类，本次提交涉及的 26 项测试在本地 Maven 测试配置下通过。 - 本地 Maven `validate` 和 `package -DskipTests` 通过。 - Apifox 15 个请求、49 项断言通过，覆盖八类指标查询、批量查询、Broker 过滤、组织过滤、空结果和时间聚合。 - 对照本地 Kafka CLI、直接 JMX 数据及 KnowStreaming Topic 元数据验证，两个 Broker 均产生节点指标样本。 Maven 测试 profile 和本地运行依赖调整保留在本地，本 PR 不包含 POM 改动。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
