pulsar

pulsar copied to clipboard

[feature request] C++ and Python support ack timeout redelivery backoff

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation [PIP 130: Apply redelivery backoff policy for ack timeout](https://github.com/apache/pulsar/issues/13528) ### Solution Refer java...

shibd

### Motivation Fix https://github.com/apache/pulsar/issues/17688 ### Modifications 1. Add missing files linked in `io-connectors` for versions `2.1.1-incubating`, `2.2.x`, `2.3.x`, `2.4.x`, and `2.5.x`. 2. Revert overwritten contents of `io-connectors` for versions `2.1.1-incubating`,...

momo-jun

[fix][client] Fix the blocked producer due to chunking when blockIfQueueFull is enabled

2

Fixes #17446 ### Motivation Producer may be permanently blocked by chunking messages when blockIfQueueFull is enabled. The reason for this bug is how the chunk message semaphore is acquired. https://github.com/apache/pulsar/blob/359cfa7bc05775bf6dd004f21b9907610ed3b3d5/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java#L520-L527...

Gleiphir2769

[improve][txn]PIP-160 make txn components supports buffered writer metrics

2

Master Issue: #15370 ### Modifications - Make transaction `MLTransactionMetadataStoreProvider` & `MLPendingAckStoreProvider` support buffered writer metrics. - Motivation: #15370 ---- - Delete constructor of `TxnLogBufferedWriter` without parameter `metrics`. - Motivation: it...

poorbarcode

### Motivation Fix testGetTxnID, testSubscriptionRecreateTopic and testPendingAckMarkDeletePosition can not pass since the broker is not cleaned up. ### Modification fix the testGetTxnID, and move the testSubscriptionRecreateTopic and testPendingAckMarkDeletePosition to adapt...

liangyepianzhou

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/actions/runs/3087399137/jobs/4996282487 ### Exception stacktrace Error: Tests run: 5, Failures: 1, Errors: 0,...

codelipenghui

[fix] [python client] Better Python garbage collection management for C++-owned objects

10

Fixes https://github.com/apache/pulsar/issues/16527 ### Motivation Copied from issue discussion: The problem is the [GIL](https://wiki.python.org/moin/GlobalInterpreterLock). When Python object reference counts are manipulated from compiled code, those manipulations are not atomic or protected...

zbentley

[Doc] How does pulsar achieve synchronous replication of data across IDCs for disaster recovery?

4

### What issue do you find in Pulsar docs? geo-replication can only replicate data asynchronously. If bookkeeper is deployed across IDCs, there is no way to ensure that entry replicas...

iamqq23ue

[fix][cpp] Use weak ptr avoid circular references.

1

### Motivation Capturing shared ptr in the timer function will cause a circular reference. ### Modifications - Use weak ptr instead shared ptr. ### Documentation - [x] `doc-not-needed`

shibd

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 2.8.1 ### Minimal reproduce step 1. unload bundle causes topic fence 2. OpAddEntry...

lightzhao