Skip to content

[ISSUE #10203] Support wildcard subscription and consume suspend for liteTopic#10204

Open
f1amingo wants to merge 1 commit intoapache:developfrom
f1amingo:feature/lite_suspend
Open

[ISSUE #10203] Support wildcard subscription and consume suspend for liteTopic#10204
f1amingo wants to merge 1 commit intoapache:developfrom
f1amingo:feature/lite_suspend

Conversation

@f1amingo
Copy link
Copy Markdown
Contributor

Which Issue(s) This PR Fixes

Brief Description

Add wildcard (*) subscription support for liteTopic to eliminate the need for manual subscription relationship maintenance. The entire wildcard subscription consumer group will share consumption of all liteTopics under a topic. Additionally, implement consume suspend mechanism to temporarily defer consumption when consumers encounter transient resource bottlenecks, improving system stability and resource utilization.

- Add wildcard (*) subscription support for liteTopic
- Implement consume suspend mechanism with invalid scan count threshold
- Refactor subscriber query interface with SubscriberWrapper for flexible retrieval
- Add wildcard client cache with 30s TTL for performance optimization
- Update related components and enhance test coverage

Change-Id: I4ecaceec7daa2f4364d911437007df98dc49d542
@codecov-commenter
Copy link
Copy Markdown

codecov-commenter commented Mar 25, 2026

Codecov Report

❌ Patch coverage is 46.37681% with 148 lines in your changes missing coverage. Please review.
✅ Project coverage is 48.79%. Comparing base (8d451f3) to head (7986de7).
⚠️ Report is 2 commits behind head on develop.

Files with missing lines Patch % Lines
...ache/rocketmq/broker/lite/LiteEventDispatcher.java 36.55% 48 Missing and 11 partials ⚠️
...che/rocketmq/broker/lite/LiteLifecycleManager.java 0.00% 18 Missing ⚠️
...etmq/broker/lite/LiteSubscriptionRegistryImpl.java 73.43% 10 Missing and 7 partials ⚠️
.../broker/offset/MemoryConsumerOrderInfoManager.java 0.00% 15 Missing ⚠️
...ketmq/broker/lite/RocksDBLiteLifecycleManager.java 0.00% 14 Missing ⚠️
...broker/processor/ChangeInvisibleTimeProcessor.java 0.00% 6 Missing ⚠️
...protocol/subscription/SubscriptionGroupConfig.java 25.00% 6 Missing ⚠️
...e/rocketmq/common/SubscriptionGroupAttributes.java 0.00% 4 Missing ⚠️
...etmq/broker/lite/AbstractLiteLifecycleManager.java 62.50% 2 Missing and 1 partial ⚠️
.../java/org/apache/rocketmq/common/BrokerConfig.java 25.00% 3 Missing ⚠️
... and 2 more
Additional details and impacted files
@@              Coverage Diff              @@
##             develop   #10204      +/-   ##
=============================================
- Coverage      48.94%   48.79%   -0.15%     
+ Complexity     13388    13348      -40     
=============================================
  Files           1373     1374       +1     
  Lines          99924   100084     +160     
  Branches       12908    12930      +22     
=============================================
- Hits           48907    48839      -68     
- Misses         45089    45262     +173     
- Partials        5928     5983      +55     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Feature] Support wildcard subscription and consume suspend for liteTopic

2 participants