pulsar

pulsar copied to clipboard

[feat] [pulsar-admin] Add remove-clusters command for namespace

8

From [dev-email](https://lists.apache.org/thread/z531k47nlzy3gvbdkthh2n2wblwgxzfs) Fixes #12822 ### Motivation CLI `bin/pulsar-admin` supports `set-clusters` and `get-clusters` command, but lacks corresponding `remove-clusters` commands, the purpose of this PR is to add this command. ### Documentation...

yuruguo

[pulsar-broker] Broker handle back-pressure with max-pending message across topics to avoid OOM

24

### Motivation We have seen multiple different scenarios when broker suddenly sees huge spike in heap-memory usage and consumes all allocated heap-memory and eventually it crashes with OOM. One of...

rdhabalia

fix: Prevent StackOverFlowException in SHARED subscription

6

*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes #16074 *(or if this PR is one task of a github issue, please add `Master Issue: #` to...

leizhiyuan

[feature][functions]Support auth for function go

10

*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes # *(or if this PR is one task of a github issue, please add `Master Issue: #` to...

liangyuanpeng

[tiered-storage] set s3 offloader use Virtual Hosted-Style as default

3

### Motivation This PR #15710 provides a common way to offload data to storages which compatible with S3 APIs. I have a test on Tencent Cloud COS (a cloud storage...

ethqunzhong

Support Tiered-Storage Provider for Tencent Cloud COS

8

### Motivation add new featrue to support tiered storage by tencent cloud cos ### Modifications Tencent Cloud COS is compatible with the S3 API. official document as below: China: https://cloud.tencent.com/document/product/436/41284...

ethqunzhong

fix: make internalSetMaxConsumersPerSubscription async

4

*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes #15856 *(or if this PR is one task of a github issue, please add `Master Issue: #` to...

leizhiyuan

Add bk rack info setting in cluster metadata setup

3

### Motivation Currently we have only Admin API `Bookies.updateBookieRackInfo()` to config rack info. If we want to setup up a pulsar cluster with some rack info config, we need to...

wangjialing218

[broker] Make ServiceConfiguration#brokerInterceptors configure dynamic

2

### Motivation Make ServiceConfiguration#brokerInterceptors configure dynamic, so that we can config broker interceptors by dynamic config api and without broker restart. ### Verifying this change - [ ] Make sure...

tjiuming

Fix delay messages are expired by TTL policy

15

Signed-off-by: xiaolongran ### Motivation The current TTL policy conflicts with delayed messages. The TTL policy does not identify how long to delay messages. When the time of the delayed message...

wolfstudy