RockteMQ-AI commented on PR #4332: URL: https://github.com/apache/rocketmq-dashboard/pull/4332#issuecomment-5682173176
## 🤖 Automated Code Review **PR:** [ISSUE #4330] Add Consumer Group Rebalance History & Partition Flapping Analyzer **Verdict: ❌ Critical Issues — Not Ready for Merge** ### 🔴 Critical: Service Returns Fabricated Rebalance Events The service implementation generates fake rebalance history using hash-based random values: ```java // ConsumerRebalanceAnalyzerServiceImpl.java int eventCount = 4 + (Math.abs(consumerGroup.hashCode()) % 8); ``` The rebalance events, partition flapping counts, and stability scores are all fabricated. This means: 1. The "flapping detection" reports non-existent partition instability 2. The "stability score" has no correlation with actual consumer group health 3. Historical timeline events are completely invented — no real rebalance data is stored or queried ### 🔴 Critical: No Persistence Layer The service claims to provide "history" but has no database or persistent storage. All data is generated on-the-fly from hash functions, meaning: - Refreshing the page gives the same fake data (deterministic from group name) - No actual historical trend analysis is possible - The "partition flapping analyzer" cannot detect real flapping patterns ### ⚠️ Other Issues - **No integration with `ConsumerOffsetManager`** or `RebalanceService`** for real rebalance data - **No event collection mechanism** — real rebalance events would need to be captured and stored - **No configurable retention period** for historical data - **No tests** for actual analysis logic (only controller endpoint tests with mocked services) ### Recommendation This PR needs: 1. Real rebalance event capture from `RebalanceService` or consumer heartbeat tracking 2. Persistent storage for historical rebalance data 3. Actual flapping detection algorithm based on real partition assignment changes 4. Integration with the consumer group management layer --- <sub>🔍 Automated review by RockteMQ-AI. Please verify suggestions before applying.</sub> -- 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]
