elephone-184 opened a new pull request, #3140:
URL: https://github.com/apache/rocketmq-dashboard/pull/3140
## Summary
This PR introduces a comprehensive Consumer Group Latency & Bottleneck
Diagnostic Engine to solve production issues where consumer lag, processing
imbalance, or stuck queues cannot be quickly diagnosed.
### Key Changes
1. **Diagnostic Model & Metrics**:
- Implemented `ConsumerDiagnosticReport` calculating client skew
variance, total lag diff, and queue imbalance.
- Categorized backlog risk levels (`NORMAL`, `MODERATE`, `CRITICAL`).
2. **Core Diagnostic Service**:
- Implemented `ConsumerDiagnosticServiceImpl` to scan message queue
consume stats, identify top bottleneck queues (diff >= 500), and evaluate
client-side queue assignment distribution.
- Built an automated rule engine to output actionable recovery
recommendations.
3. **REST API & Frontend Modal**:
- Added `ConsumerDiagnosticController` mapped to
`/consumer-diagnostic/diagnose.query`.
- Created React component `ConsumerDiagnosticModal.jsx` to visualize
group latency metrics, bottleneck table, and client balance.
## Test Plan
- Unit tests for `ConsumerDiagnosticServiceImpl` verifying skew calculation
logic.
- REST API endpoint verification with mock consumer group lag inputs.
--
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]
