-
Notifications
You must be signed in to change notification settings - Fork 11.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[ISSUE #7543] Retry topic v2 in pop #7544
Conversation
We need to consider the modifications from #7208 in order to ensure compatibility. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We need to consider the modifications from #7208 in order to ensure compatibility.
+1, it will only delete the v2 topic instead of the v1 topic
common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
Outdated
Show resolved
Hide resolved
* calculate consumer lag * delete retry topic
fixed |
Can the forward slash be used for folders in Linux? The "topic" of Pop ultimately ends up as a folder on the machine? Or, in other words, is the design utilizing a multi-level directory to support this type of topic? |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Change the separator from '/' to ':' to prevent multi-level directory case. |
* Implement pop retry topic v2 * Use pop retry topic v2 to notify the origin topic * add parse group * retry topic v2 compatibility * calculate consumer lag * delete retry topic
Which Issue(s) This PR Fixes
Fixes #7543
Brief Description
Use new retry topic to solve pop retry topic message notification and split group from retry topic.
How Did You Test This Change?
Unit test.