Cong Zhao

PIP-195: New bucket based delayed message tracker

2

# PIP-195: New bucket based delayed message tracker Discussion Mailing list thread: https://lists.apache.org/thread/1krdhrvs803kb6rqzdh17q0f199nroz4 Vote Mailing list thread: https://lists.apache.org/thread/51n8kp64d16vxwh9h6klvyh1zo0owf91 ## Motivation Scheduled and delayed message delivery is a widespread feature in...

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...

[feature][broker] Support cgroup v2 by using `jdk.internal.platform.Metrics` in Pulsar Loadbalancer

2

Master Issue: #16601 ### Motivation The Pulsar load balancer detects CPU limits using cgroup v1 API, and the `jdk.internal.platform.Metrics` already support cgroup (V1, v2) so we should use `jdk.internal.platform.Metrics` to...

[improve][client-c++] Use an atomic `state_` instead of the lock to improve performance

6

### Motivation Now, Use a lot of locks to ensure the atomicity of `state_` in the `ConsumerImpl`, `ProducerImpl`, `PartitionedConsumerImpl`, and `MultiTopicsConsumerImpl`, we can use atomic `state_` instead of the lock...

[fix][doc] fix `ackReceiptEnabled` doc

3

Fixes #16449 ### Motivation The add `ackReceiptEnabled` doc is not correct in PR #16465, need to correct the docs. ### Modifications Fix `ackReceiptEnabled` doc. ### Documentation Check the box below...

Support exchange properties

2

Master Issue: #631 ### Motivation Support exchange properties ### Modifications *Describe the modifications you've done.* ### Verifying this change - [ ] Make sure that the change passes the CI...

Master Issue: #16763 ### Motivation #16763 ### Modifications Implement BookkeeperBucketSnapshotStorage and add unit test. ### Verifying this change - [x] Make sure that the change passes the CI checks. ###...

[feat][broker][PIP-195] Implement BucketDelayedDeliveryTrackerFactory and load BucketDelayedDeliveryTracker - part5

1

Master Issue: #16763 ### Motivation #16763 ### Modifications * Implement BucketDelayedDeliveryTrackerFactory. * Change DeliveryTrackerFactory interface to adapter BucketDelayedDeliveryTrackerFactory. * Load BucketDelayedDeliveryTracker. ### Verifying this change - [x] Make sure that...

[feat][broker][PIP-195] Support internal cursor properties - part4

3

Master Issue: #16763 ### Motivation Now, the cursor properties support overall update and modifying a single value concurrently by #17164, but `setCursorProperties` will all key-value is removed before update properties,...

[feat][broker][PIP-195] Implement delayed message index bucket snapshot (create/load) - part2

5

Master Issue: #16763 ### Motivation #16763 ### Modifications * Implement delayed message index bucket * Implement delayed message index bucket snapshot (create/load) * Reuse and refactor InMemoryDelayedDeliveryTracker * Reuse and...