Comments (4)
- can you describe your usecase where this feature can be helpful?
- and in that usecase: what could be the variables based on which user assign priority level of each consumer? Is it based on machine's capacity or configuration?
from pulsar.
the consumer may be assigned different priority based on the machine's capacity or location(e.g. rack or idc).
we would like the consumers in the master application cluster to consume the whole message as most as possible, if the master application cluster crash totally, the consumers in the other cluster can continue to consume the messages, but with different costing.
from pulsar.
That was what I had in mind as well.
My other question would be: would anyone need in practice more that 2 priorities (High
and Low
)?
from pulsar.
would anyone need in practice more that 2 priorities (High and Low)?
Currently we only require 2 priorities in the applications, but I think it's better to have the ability to have multiple priorities.
from pulsar.
Related Issues (20)
- [Bug] [cli] Pulsar-client cli doesn't support timeout values given in apache pulsar reference website
- [Bug] [cli] Pulsar Tokens Create is mishandling time units (specifically, treating seconds as milliseconds) HOT 1
- Excessive memory allocation in OTel broker metrics HOT 3
- [Bug] pulsar-admin 2.x links don't properly link to 3.2 HOT 6
- [Bug] Offload to S3 triggered manually returns success, while not uploading HOT 2
- [Bug] Broker became irresponsive due to deadlock during race-condition in metadatastore callback
- [Bug] Broker is failing to load stats-internal with broken schema ledger
- [Doc] Incorrect description of UniformLoadShedder in pulsar site. HOT 1
- [Doc] PIP-356: Improve "Support Geo-Replication starts at earliest position" doc
- [Bug][client] Consumer implementation might change message processing order when ack timeout is set
- High GC pause cases high publish latency HOT 3
- Flaky-test: ExtensibleLoadManagerImplTest.testGetMetrics (fails consistently)
- [Bug] bin/pulsar-zookeeper-ruok.sh fails with apachepulsar/pulsar:3.3.0 image
- [Bug] maven build fails with Java 22 HOT 1
- [Bug] nslookup in apachepulsar/pulsar:3.3.0 isn't compatible with kubernetes search domains
- Pulsar Standalone: --wipe-data does not work with RocksDB backend in 3.2.3
- [Doc] Search doesn't work on pulsar website HOT 2
- [Bug] [docs] Pulsar 3.3 javadoc is in Chinese HOT 1
- [Bug] Broker became irresponsive due to too many open files error HOT 2
- [Doc] Document the removal of compaction
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from pulsar.