道君

[feat][monitor] PIP-222: Add PartitionMetadataRequest metrics

1

PIP: https://github.com/apache/pulsar/issues/18319 ### Motivation https://github.com/apache/pulsar/issues/18319 ### Modifications ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of the following options)*...

[feat][monitor] PIP-223: Add metrics for all rest endpoints.

1

PIP: https://github.com/apache/pulsar/issues/18560 ### Motivation https://github.com/apache/pulsar/issues/18560 ### Modifications ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of the following options)*...

[libbeat] Introduce Apache Pulsar to beats as an output plugin

30

## Proposed commit message Introduce Apache Pulsar to beats as an output plugin, and users could send data to Pulsar. ## Checklist - [x] My code follows the style guidelines...

Fixes https://github.com/apache/pulsar-client-go/issues/1103 ### Motivation Introduce `BooleanSchema` ### Modifications Add `BooleanSchema` ### Verifying this change - [x] Make sure that the change passes the CI checks. *(Please pick either of the...

[feat] Add Reader interceptor

3

Fixes https://github.com/apache/pulsar-client-go/issues/937 ### Motivation Add Reader interceptor ### Modifications *Describe the modifications you've done.* ### Verifying this change - [ ] Make sure that the change passes the CI checks....

[feature] Message payload processor

2

refer to: https://github.com/apache/pulsar/wiki/PIP-96%3A-Message-payload-processor-for-Pulsar-client

[fix] Fix Reader can be stuck from transaction aborted messages.

9

### Motivation Fix Reader can be stuck from transaction aborted messages. Related to https://github.com/apache/pulsar/pull/22572 Since Reader's SubscriptionType is `Exclusive`, so we no need to handle DelayedDelivery messages. ### Modifications ###...

[improve][ml] Optimize read entries with skipCondition

3

### Motivation In https://github.com/apache/pulsar/pull/19035 we introduced `skipCondition` to filter-out delay delivery messages before read entries from Bookkeeper, and in https://github.com/apache/pulsar/pull/21739, we also filter-out deleted(individual acked messages) before read entries. However,...

[improve][offload]PIP-211: Introduce Offload throttling, P1

5

PIP: https://github.com/apache/pulsar/issues/18004 ### Motivation See https://github.com/apache/pulsar/issues/18004 ### Modifications 1. Move AsyncTokenBucket related classes from pulsar-broker to pulsar-common 2. Add OffloadLedgerHandle.java 3. Pass OffloadLedgerHandle's instance to LedgerOffloader instead of LedgerHandle. ###...

[improve][broker] Optimize seeking by timestamp

15

Fixes https://github.com/apache/pulsar/issues/22129 Main Issue: #xyz PIP: #xyz ### Motivation Optimize seeking by timestamp ### Modifications Add a new method to ManageCursor. ### Verifying this change - [ ] Make sure...