pulsar

pulsar copied to clipboard

[improve][client] Add maxConnectionsPerHost and connectionMaxIdleSeconds to PulsarAdminBuilder

7

Fixes #22041 ### Motivation See #22041 . Currently, when using the asynchronous interfaces of the Pulsar Admin client, there's no backpressure by the client itself and the client will keep...

lhotari

[Bug] Client with shared subscription is blocked

29

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Client - 3.1.0 Pulsar - 3.1.0 (and later builds) Also reported on 3.0.1...

michalcukierman

[improve][pip] PIP-346: Add a simplified configuration file for Pulsar

6

### Motivation PIP-346 ### Verifying this change - [x] Make sure that the change passes the CI checks. *(Please pick either of the following options)* This change is a trivial...

thetumbled

Cleanup synchronous call in resources component

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation We should clean up all the synchronous call for resources components to avoid...

mattisonchao

[improve][client] Client add permits metric

1

### Motivation Added a new dimensional metric to help better monitor clients. ### Modifications Add `pulsar.client.consumer.available_permits.count` metric. ### Verifying this change - [x] Make sure that the change passes the...

crossoverJie

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

dao-jun

Consumer able to receive message which is not matching the regex pattern

9

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [X] I understand that unsupported versions don't get bug fixes....

ragaur-tibco

[fix] Bump google.golang.org/protobuf from 1.32.0 to 1.33.0 in /pulsar-function-go

1

Bumps google.golang.org/protobuf from 1.32.0 to 1.33.0. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) You can trigger a rebase of this PR by commenting `@dependabot rebase`. [//]: # (dependabot-automerge-start) [//]: # (dependabot-automerge-end) --- Dependabot commands...

dependabot[bot]

[Bug] Cannot build on Apple Arm

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [X] I understand that unsupported versions don't get bug fixes....

chenrui333

Flaky-test: NamespaceAuthZTest.testPermission

4

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/actions/runs/8614618958/job/23608820624?pr=22464#step:11:1452 ### Exception stacktrace ``` Error: Tests run: 31, Failures: 1, Errors:...

lhotari