pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation If you want to create a TestClient which uses AuthenticationKeyStoreTls as its authPlugin,...
Fixes #14101 ### Motivation SchemaRegistryService is hardcoded to use SchemaRegistryServiceImpl in org.apache.pulsar.broker.service.schema.SchemaRegistryService#create ### Modifications broker.conf has a new config called schemaRegistryClassName which will have the name of the class to...
### Motivation In some client use cases, it is helpful to start attempting to refresh the OAuth2 token before it has expired. This PR adds that functionality. The core addition...
### Motivation Since https://github.com/apache/pulsar/pull/6428, we can define authz policy to each namespace operation. However, I think the operation policy `validateNamespacePolicyOperation(namespaceName, PolicyName.ANTI_AFFINITY, PolicyOperation.READ);` is not suitable for `getAntiAffinityNamespaces` method because this...
Master Issue: #13559 ### Motivation If topic is configured to offload, automatically offload compacted ledger into tiered storage. ### Modifications Offload compacted ledger into tiered storage. ### Does this pull...
Fixes #12165 ### Motivation The bundle unloading of one producer or consumer will not affect other prodcers or consumers which belong to the same client and share the same connection....
### Motivation Fixes #13269 ### Modifications When message is put into `possibleSendToDeadLetterTopicMessages`, do not clear it in `release()` since it will be used when send to DLQ later. And clear...
### Motivation We have introduced poolMessages for consumer by PIP-83, and add configuration for functions by #11618 The default value of poolMessage is false if user did not config it...
### Motivation We have admin api to list bundles of a broker, but we could not get the stats of each bundle. Sometimes we need to known the throughput and...
### Motivation We added Uniform load balancer strategy in #12902 which considers all the brokers and distributes the load uniformly across all available brokers. However, it doesn't consider namespace isolation...
