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] Checkstyle check is not applied to all tests HOT 1
- [Security] 3.3.0 has several fixable security vulnerabilities. HOT 8
- [Bug] Breaking contract b/w 2.9 / 2.10 and 3.0 for ns-isolation-policy
- [Bug] org.apache.pulsar:pulsar-package-bookkeeper-storage:jar:3.4.0-SNAPSHOT was not found HOT 2
- [Bug][Broker] Topic load stuck and become unavailable HOT 1
- [Doc] Inconsistencies in bookie instance type and terraform related command HOT 1
- [Doc] add golang transaction demo in txn-use.md
- Encryption performance improvement on Java client HOT 4
- [Bug] The Elected Leader Broker Thinks It's a Follower
- [Bug] Pulsar Admin client will timeout requests with the read timeout value and retry in the background up to 5 times
- [Bug] Use the plusar and spring aop ,the aop failed
- [Chore][Doc] Run a Pulsar cluster locally with Docker Compose HOT 1
- [Bug][client] Delay messages can be ack before reaching the delivery time HOT 2
- [Doc] Adding hyperlink jumps for keywords
- Revisit TableView/Builder Listener Interface HOT 2
- [Bug] [Regression] etcd mTLS doesn't work on 3.3.1 HOT 1
- Flaky-test: CurrentLedgerRolloverIfFullTest.testCurrentLedgerRolloverIfFull HOT 3
- Flaky-test: AdminApiTransactionTest.testGetTransactionBufferInternalStats
- Flaky-test: ManagedLedgerTest.testDeleteCurrentLedgerWhenItIsClosed
- [Bug] java client 3.3.1: newConsumer topicsPattern : java.util.regex.PatternSyntaxException: Illegal/unsupported escape sequence near index “^public/default/pulsar-test-1\E$” HOT 1
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.