-
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] Heartbeat topic enable checkMessageExpire #20832
[improve][broker] Heartbeat topic enable checkMessageExpire #20832
Conversation
The fix is good, Could you add a test? |
Test is done. @Technoboy- |
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
/pulsarbot rerun-failure-checks |
The pr had no activity for 30 days, mark with Stale label. |
03e289b
to
12b5119
Compare
Actually in our pulsar environment, compaction is trigger, thats the reason why ledger not clean. With this pr, #14643. Heartbeat topic no longer trigger compaction. This problem can be fix. So close this pr. |
Motivation
Running pulsar cluster for a long time, we found there are thousands of ledgers of heartbeat topic. The reason is heartbeat topic do not clean the expired message because it is systemTopic. The behaviour change since this pr #13611.
I think it is no need to keep heartbeat topic message permanently and we'd better clean the expired message and the ledger.
Modifications
modify checkMessageExpire()
Verifying this change
Does this pull request potentially affect one of the following parts:
If the box was checked, please highlight the changes
Documentation
doc
doc-required
doc-not-needed
doc-complete
Matching PR in forked repository
PR in forked repository: