-
Notifications
You must be signed in to change notification settings - Fork 3.6k
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 5903] Support compact
all partitions of a partitioned topic
#6537
Conversation
verify(response, timeout(5000).times(1)).resume(responseCaptor.capture()); | ||
Assert.assertEquals(responseCaptor.getValue().getStatus(), Response.Status.NO_CONTENT.getStatusCode()); | ||
|
||
// create partitioned topic and compaction on it |
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.
@murong00 thanks for the contribute, Would you please help add a test that really called into and execute the compact? Seems this is only the top level method call, and not called into the methods, and some of the code in PersistentTopicsBase.java seems not covered.
If there is no ut framework for this, we could add a integration test for it.
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.
Added a unit test to cover the compact logic and just keep this top level method call test.
@jiazhai I hava added a unit test to cover the compact logic, please help to take a look. |
/pulsarbot run-failure-checks |
…pache#6537) * Resolve conflict. * Add a unit test to cover the compact logic.
Motivation
Fixes #5903
If there is a partitioned topic with too many partitions, users need to
compact
one by one.Modifications
Async method
triggerCompaction
and support tocompact
on a partitioned topic.