pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
### Motivation Now we don't check `OpAddEntry` can read entry is smaller than maxReadPosition, if readPosition is bigger than maxReadPosition, we only can read an empty list as result. In...
### Motivation As default, Broker log level set by `log4j2.yaml` with `pulsar.log.level=info`, if developers want to update log level to debug, need to Modify `log42j.yaml#pulsar.log.level=debug` and then restart Broker service....
Master Issue: https://github.com/apache/pulsar/issues/17625 ### Motivation Add a new api named clientStats to proxy stats ### Modifications see issue ### Verifying this change - [x] Make sure that the change passes...
Fixes #17574 Master Issue: #17574 ### Motivation Email from Yunze Xu Assuming users called "acknowledgeCumulative" periodically, there is a chance that some messages of the specific partition has never been...
Fixes https://github.com/apache/pulsar/issues/15450 ### Motivation Currently after calling `delete-cluster-metadata` there're still metadata remain under `/admin` and `/pulsar` path which could cause trouble if zookeeper is shared between different Pulsar clusters. ###...
### Motivation Supports assigning bundles to a given broker. 1. Write the corresponding allocation scheme on zk through a command; 2. When the bundle is unloaded, at the time of...
### Motivation *consumer client has method pause(), but consumer is not really paused. paused consumer only stop send flow permit request to broker but broker still can push messages to...
resolves: https://github.com/apache/pulsar/issues/17094 ### Motivation improve perf 1. we not need add lock when `MsgMetadata.hasDeliverAtTime` return false. 2. use double check lock to init `DelayedDeliveryTracker` and `InMemoryDelayedDeliveryTracker#addMessage` add `synchronized` to ensure...
prefer to use index in BrokerEntryMetadata and considering batchIndex when build sequenceId. Fixes #17061 ### Motivation In pulsar function EFFECTIVELY_ONCE semantic, producer attach a sequenceId to output topic for deduplication,...
### Motivation [PIP 61](https://github.com/apache/pulsar/wiki/PIP-61%3A-Advertised-multiple-addresses) and [PIP 95](https://github.com/apache/pulsar/issues/12040) supports multiple advertised address for binary port. For HTTP port, currently we do not have a way to support multiple advertised address. Consider...
