Skip to content
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

We need a size limit for cache of single managedLeger #22621

Open
2 tasks done
KernLC opened this issue Apr 30, 2024 · 2 comments
Open
2 tasks done

We need a size limit for cache of single managedLeger #22621

KernLC opened this issue Apr 30, 2024 · 2 comments
Labels
type/enhancement The enhancements for the existing features or docs. e.g. reduce memory usage of the delayed messages

Comments

@KernLC
Copy link

KernLC commented Apr 30, 2024

Search before asking

  • I searched in the issues and found nothing similar.

Motivation

When a topic produce too much messages, the caches of broker will be full with this topic. In this case, the fetch request of other consumers cannot hit the cache and they only can read entries by bookeeper.

Solution

Add a size limit for cache of single managedLedger.

Alternatives

~

Anything else?

~

Are you willing to submit a PR?

  • I'm willing to submit a PR!
@KernLC KernLC added the type/enhancement The enhancements for the existing features or docs. e.g. reduce memory usage of the delayed messages label Apr 30, 2024
@lhotari
Copy link
Member

lhotari commented May 8, 2024

Yes, the current broker cache isn't optimal. Please participate in this dev mailing list discussion: https://lists.apache.org/thread/xm095hnjo0cffbdy8ckysmzzm90gsbnp .
There are mailing list joining instructions at https://pulsar.apache.org/contact/

Add a size limit for cache of single managedLedger.

Instead of a size limit, the caching algorithm should have a proper way to do optimal decisions and set the limits dynamically based on the load.

@lhotari
Copy link
Member

lhotari commented May 8, 2024

There's also "PIP-174: Provide new implementation for broker dispatch cache" #15954 / #15955 to improve broker cache.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
type/enhancement The enhancements for the existing features or docs. e.g. reduce memory usage of the delayed messages
Projects
None yet
Development

No branches or pull requests

2 participants