f1amingo opened a new pull request, #10623: URL: https://github.com/apache/rocketmq/pull/10623
### Which Issue(s) This PR Fixes - Fixes #10622 ### Brief Description Projects that build on top of this core may replace the `ConsumerOffsetManager` implementation at the upper level. The dispatcher currently caches the manager as a final field at construction time, so the customized manager never takes effect. This PR resolves the manager lazily via `brokerController.getConsumerOffsetManager()` instead of caching it in a field, allowing downstream projects to swap in their own implementation after the broker is fully initialized. ### How Did You Test This Change? Existing unit tests cover the dispatcher logic. The change is minimal (2 insertions, 5 deletions) and does not alter behavior — only the resolution path. -- 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]
