pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
### Motivation We update some cache dynamic configurations, such as: managedLedgerCacheSizeMB=100, but after we restarted the broker, we found that the dynamically modified cache configuration on zookeeper was invalid, and...
Master Issue: https://github.com/apache/pulsar/issues/16521 ### Motivation - Fixes https://github.com/apache/pulsar/issues/16521 - If the broker responds quickly enough, there may never be concurrency in requests, so we use a `Semaphore` to block the...
Fixes https://github.com/apache/pulsar/issues/16596 ### Motivation add per-subscription `EntryFilter` metrics for PersistentTopic and NonPersistentTopic. ### Modifications Add the following metrics to Prometheus: 1. pulsar_subscription_through_filter_msg_count 2. pulsar_subscription_filter_accepted_msg_count 3. pulsar_subscription_filter_rejected_msg_count 4. pulsar_subscription_filter_rescheduled_msg_count Add the...
Fixes #16949 ### Motivation Now, sending messages to the consumer using io-thread. When the task is scheduled, the message ack may be already changed leading to delivering the message of...
Fixes #15891 Master Issue: #15891 ### Motivation Pulsar-manager could see all the topics including the system topic and can terminate them. If terminates system topic by mistake, there would cause...
### Motivation default value of logSizeLimit is 1G since bookkeeper-4.4.0 https://github.com/apache/bookkeeper/commit/10cab08d0a8b4ca4b182554dee95834dc42175d2 pulsar-2.x use bookkeeper-4.7.0 or above. https://github.com/apache/pulsar/blob/v2.0.1-incubating/pom.xml#L120 ### Modifications * Change default value of logSizeLimit(1073741824->2147483648) ### Verifying this change -...
### Motivation Currently, Java tests consume major CI resources. And it is not necessary to run all the tests for changes that are only on the C++ or python parts...
Python Client document writes: ``` # avro serialization $ pip install pulsar-client[avro]=='2.10.1' # functions runtime $ pip install pulsar-client[functions]=='2.10.1' # all optional components $ pip install pulsar-client[all]=='2.10.1' ``` However, all...
Related to https://github.com/apache/pulsar-site/issues/146. ### Motivation * Websocket is not a language but a language-agnostic interface. ### Modifications 1. Separate language-specific and language-agnostic clients. 2. Improve third-party client libraries display -...
### Motivation Refer to [PIP-190](https://github.com/apache/pulsar/issues/16637). ### Modifications 1. Rename version-2.8.0/2.9.0/2.10.0 to version-2.8.x/2.9.x/2.10.x 2. Add 2.8.1/2.8.2/2.8.3 specific doc changes to 2.8.x docs. 3. Add 2.9.1/2.9.2/2.9.3 specific doc changes to 2.9.x docs....
