-
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
[improve][broker][PIP-318] Support not retaining null-key message during topic compaction #21578
Conversation
7fbe7b5
to
cb1b764
Compare
pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawBatchConverter.java
Show resolved
Hide resolved
pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawBatchConverter.java
Outdated
Show resolved
Hide resolved
ad93df2
to
4ff06cf
Compare
pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawBatchConverter.java
Show resolved
Hide resolved
a1ae5f1
to
1ca9ce5
Compare
Codecov Report
Additional details and impacted files@@ Coverage Diff @@
## master #21578 +/- ##
============================================
+ Coverage 73.27% 73.29% +0.02%
- Complexity 32676 32705 +29
============================================
Files 1892 1892
Lines 140632 140721 +89
Branches 15467 15489 +22
============================================
+ Hits 103044 103146 +102
+ Misses 29497 29470 -27
- Partials 8091 8105 +14
Flags with carried forward coverage won't be shown. Click here to find out more.
|
…during topic compaction (apache#21578)
@@ -538,6 +538,9 @@ brokerServiceCompactionThresholdInBytes=0 | |||
# If the execution time of the compaction phase one loop exceeds this time, the compaction will not proceed. | |||
brokerServiceCompactionPhaseOneLoopTimeInSeconds=30 | |||
|
|||
# Whether retain null-key message during topic compaction | |||
topicCompactionRemainNullKey=false |
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.
topicCompactionRemainNullKey=false | |
topicCompactionRetainNullKey=false |
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.
@coderzc I just saw this typo in the config key :)
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.
Sorry, I open a new PR to fix it. #21690
… compaction (#21578) (#21665) Co-authored-by: fengyubiao <[email protected]>
… compaction (apache#21578) (apache#21601) (cherry picked from commit 6ddf83d)
… compaction (apache#21578) (apache#21601) (cherry picked from commit 6ddf83d)
PIP: #21541
Motivation
Implement #21541
Modifications
topicCompactionRetainNullKey
in the broker.conf, the default value is false.Verifying this change
(Please pick either of the following options)
This change is a trivial rework / code cleanup without any test coverage.
(or)
This change is already covered by existing tests, such as (please describe tests).
(or)
This change added tests and can be verified as follows:
(example:)
Documentation
doc
doc-required
doc-not-needed
doc-complete
Matching PR in forked repository
PR in forked repository: