pulsar
pulsar copied to clipboard
Apache Pulsar - distributed pub-sub messaging system
change pulsar.log.level in log4j2.yaml not work? **Describe the bug** i modify the value of `pulsar.log.root.level` and `pulsar.log.level` from `info` to `warn` in `conf/log4j2.yaml` without restart broker service. as follow: as...
### Motivation I switched the log level from info to debug by the `pulsar.log.level` and `pulsar.log.root.level` values in the `log4j2.yaml` file, but there is no debug log for pulsar in...
### Motivation The time value should not be a negative value. We need to add a check when get a time value input. ### Modifications Add a check when get...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 3.2.0 ### Minimal reproduce step / ### What did you expect to see?...
### Motivation Currently, if only broker-level EntryFilters are used, each topic will repeatedly load EntryFilters, which is unnecessary. ### Modifications If only broker-level EntryFilters are set, then we don't load...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation When I set up a standalone that enables mTLS authentication according to the...
Main Issue: https://github.com/apache/pulsar/issues/21347 ### Motivation When the client machine's clock is incorrect (eg: set to 1 year later) and the Broker does not set the AppendBrokerTimestampMetadataInterceptor, the Ledger will not...
Fixes https://github.com/apache/pulsar/issues/21905 ### Motivation In class UniformLoadShedder, we add a fixed delta value of 1000 when calculating msgRateRequiredFromUnloadedBundles and msgThroughputRequiredFromUnloadedBundles.This will cause the load balancing strategy to fail in low...
### Motivation When message send message failed and there is a pending read, cursor.rewind() set the read position back to mark delete position, but pending read will use old position,...
### Motivation Fix typos in class PersistentReplicator and PersistentDispatcherSingleActiveConsumer ### Modifications The past participle of the word `rewind` is `rewound` rather than `rewinded` ### Documentation - [ ] `doc` -...