Skip to content
New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

[improve] [pip] PIP-299: Stop dispatch messages if the individual acks will be lost in the persistent storage #21118

Merged
merged 24 commits into from
Oct 12, 2023

Conversation

poorbarcode
Copy link
Contributor

@poorbarcode poorbarcode commented Sep 4, 2023

Documentation

  • doc
  • doc-required
  • doc-not-needed
  • doc-complete

Matching PR in forked repository

PR in forked repository: x

@poorbarcode poorbarcode self-assigned this Sep 4, 2023
@poorbarcode poorbarcode added this to the 3.2.0 milestone Sep 4, 2023
@github-actions github-actions bot added type/PIP doc-required Your PR changes impact docs and you will update later. labels Sep 4, 2023
@poorbarcode
Copy link
Contributor Author

@asafm could you also take a look if you have time?

@poorbarcode poorbarcode changed the title [improve] [pip] PIP-299: A limitation for the max size of cursor metadata to persist [improve] [pip] PIP-299: Stop dispatch messages if the individual acks will be lost in the persistent storage Sep 13, 2023
poorbarcode and others added 2 commits October 11, 2023 10:45
Co-authored-by: Penghui Li <penghui@apache.org>
Co-authored-by: Penghui Li <penghui@apache.org>
@mattisonchao
Copy link
Member

Hi, @poorbarcode
Do you wanna make this configuration enabled by default in the future? if so, we can add the planning to the proposal. :)

@poorbarcode
Copy link
Contributor Author

@mattisonchao

Do you wanna make this configuration enabled by default in the future? if so, we can add the planning to the proposal. :)

That is a good suggestion, the next PIP will do these two things:

  • Provide a new config maxAckStatePersistentInBytes to instead managedLedgerMaxUnackedRangesToPersist, and deprecated managedLedgerMaxUnackedRangesToPersist. And set the default value of maxAckStatePersistentInBytes to 5m
  • Make this dispatcherPauseOnAckStatePersistentEnabled enabled by default

@mattisonchao
Copy link
Member

Okay, Sounds good to me. Thanks for your contribution. :)

@liudezhi2098
Copy link
Contributor

Hi @poorbarcode, do we have metrics to monitor this phenomenon for convenient monitoring and alerting?

@poorbarcode
Copy link
Contributor Author

Hi @poorbarcode, do we have metrics to monitor this phenomenon for convenient monitoring and alerting?

Only pulsar_subscription_unacked_messages is helpful for this case right now.

After the next PIP(see #21118), I will add a new metrics pulsar_subscription_metadata_size

# for free to join this conversation on GitHub. Already have an account? # to comment
Labels
doc-required Your PR changes impact docs and you will update later. type/PIP
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants