道君

PIP: 345 ### Motivation ### Modifications ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of the following options)* This...

[Improve] Introduce Apache Pulsar client monitoring support

3

## Is your feature request related to a problem? ## Describe the solution you'd like Support Apache Pulsar client monitoring ## Describe alternatives you've considered ## Additional context

[improve] Prevent memory copy and heap memory allocation when read entry

3

### Motivation Prevent memory copy when read entry. ### Changes (Describe: what changes you have made) Master Issue: # > --- > In order to uphold a high standard for...

In [PIP-363]( https://github.com/apache/pulsar/pull/22940), Pulsar will change the `org.apache.pulsar.client.impl.SendCallback#sendComplete` method sign from ```java public void sendComplete(Exception e) ``` to ```java public void sendComplete(Exception e, OpSendMsgStats stats) ``` As we wrapped `org.apache.pulsar.client.impl.SendCallback#sendComplete`...

[improve][ml] Support Bookkeeper batch read

1

### Motivation In [BP-62](https://github.com/apache/bookkeeper/pull/4051), Bookkeeper starting to support batch read API, the PR is to support Bookkeeper batch reading on the Pulsar side. ### Modifications 1. Support Bookkeeper batch read...

### Motivation Introduce gRPC SchemaStorage ### Modifications ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of the following options)*...

[plugin][pulsar] Handle the SendCallback method sign changed.

2

In https://github.com/apache/pulsar/pull/22940, Pulsar will change the `org.apache.pulsar.client.impl.SendCallback#sendComplete` method sign from ```java public void sendComplete(Exception e) ``` to ```java public void sendComplete(Throwable t, OpSendMsgStats stats) ``` This PR is to address...

[improve] Expose asyncBatchReadUnconfirmed to ReadHandle.

1

### Motivation Expose LedgerHandle#asyncBatchReadUnconfirmedEntries to ReadHandle interface. ### Changes (Describe: what changes you have made) 1. Add `batchReadUnconfirmedAsync`, `batchReadUnconfirmed` methods to `ReadHandle` 2. Implement `ReadHandle#batchReadUnconfirmedAsync` in `LedgerHandle` class. 3. Implement...

### Motivation Change log-level to debug when checking param `maxSize` in LedgerHandle#batchReadEntriesInternalAsync. In some conditions, we don't know what's the size of the entries to be read, so we pass...