pulsar

pulsar copied to clipboard

[improve][broker] ResourceGroupService alloc much memory even we do not use

4

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation add a switch to open resource group usage this will use more cpu...

leizhiyuan

[Bug] NPE throwed when recovering ledger: Cannot read field "distributionSchedule" because "this.lh" is null

8

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Pulsar 2.11 ### Minimal reproduce step I don't know how to reproduce it...

zhaohaidao

### Motivation A PIP proposal supports WASM Function API. ### Documentation - [x] `doc` - [ ] `doc-required` - [ ] `doc-not-needed` - [ ] `doc-complete`

loongs-zhang

[fix][broker] Create new ledger after the current ledger is closed

11

### Motivation #### Background 1. Managerledger has a configuration `maximumRolloverTimeMs` to configure the max time of closing a ledger. 2. The current ledger can be rollover when it reaches `maximumRolloverTimeMs`....

liangyepianzhou

[fix][fn] Unwrap type from CompletableFuture when getting function's type args

1

Fixes #22067 Main Issue: #xyz PIP: #xyz ### Motivation When inferring function type args, it doesn't unwrap the `CompletableFuture` type ### Modifications unwrap the `CompletableFuture` type for the output ###...

jiangpengcheng

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 220a3d601602d67f5f44516c5d9895dfaa270380 ### Minimal reproduce step 1. Write an async function like below: ```...

jiangpengcheng

[fix][Offload] fix indexEntries NullPointerException error

4

### Motivation Offloader exception occurs ``` 21:54:32.360 [offloader-OrderedScheduler-14-0] ERROR org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - Unknown exception for ManagedLedgerException. org.apache.bookkeeper.mledger.ManagedLedgerException$OffloadReadHandleClosedException: Offload read handle already closed 21:54:32.424 [offloader-OrderedScheduler-14-0] WARN org.apache.bookkeeper.common.util.SingleThreadSafeScheduledExecutorService - Unexpected throwable from task...

graysonzeng

[fix] [broker] Subscription stuck due to called Admin API analyzeSubscriptionBacklog

1

### Motivation The Admin API `analyzeSubscriptionBacklog` will create an `OpReadEntry` and trigger a read, which leads `Managecursor.readPosition` to move forward. It makes the subscription stuck(just like the consumer receives messages...

poorbarcode

### Motivation If a consumer tries to subscribe to a partitioned topic with a suffix-matched regexp, it does not work. - create topic `persistent://public/default/tp` - create a consumer with regexp...

poorbarcode

[branch-2.10][improve][broker] Do not retain the data in the system topic

1

### Motivation For some use case, the users need to store all the messages even though these message are acked by all subscription. So they set the retention policy of...

liangyepianzhou