pulsar
pulsar copied to clipboard
Apache Pulsar - distributed pub-sub messaging system
### Motivation When updating the currentLedger, it is necessary to ensure that the updated ledgerId is greater than the ledgerId of the current currentLedger. ### Documentation Check the box below...
### Motivation - currently there's a problem that the replicators get shutdown in the inactivity check - this is an improved fix for the issue described in #11382 ### Modifications...
Original issue: #13238 PIP Issue: #16569 ### Motivation In current ledger deletion, we divided it into two separate steps. It happens in ManagedLedger and ManagedCursor. Remove all the waiting to...
*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes # Master Issue: # ### Motivation Pulsar Function will run failed when pulsar standalone restart, the reason is...
### Motivation - Extensible Load Balancer cannot split bundles when a namespace is recreated. The old parent bundle before split (in the Deleted state) could block the next split operation...
### Motivation add metrics data flow control when Prometheus scrape metrics, to prevent high network usage. ### Modifications 1. add `MetricsDataFlowController` class 2. add `metricsDataFlowPermitPerSecond` configuration ### Documentation Check the...
### Motivation Verify the arm64 image build. ### Modifications - Use the matrix feature to verify the build of the linux/amd64 and linux/arm64 images. ### Documentation - [ ] `doc`...
### Motivation `ModularLoadManagerImpl` rely on zk to store and synchronize metadata about load, which pose greate pressure on zk, threatening the stability of system. Every broker will upload its `LocalBrokerData`...
### Motivation #22746 ### Modifications - Support `--show-server-marker` and `--show-txn-aborted`, `--show-txn-uncommitted` flags for peek-messages cmd. ### Verifying this change - Add `testPeekMessageForSkipTxnMarker`, `testPeekMessageForSkipAbortedAndUnCommittedMessages` and `testPeekMessageForShowAllMessages` unit test to corver this...
Fixes #22601 #21892 #19460 ### Motivation In Pulsar, there are multiple reported issues where the transferred output gets corrupted and fails with exceptions around invalid reader and writer index. One...