pulsar
pulsar copied to clipboard
Apache Pulsar - distributed pub-sub messaging system
### Motivation There is a race condition that makes an orphan replicator in the original owner of a topic, and causes the new owner of the topic can not start...
### Motivation When attempting to load an RSA private key in PKCS#8 format for message encryption, the key loading fails. ### Modifications When the RSA private key is in PKCS#1...
### Motivation Fix the incorrect metrics name. Reference links: https://github.com/apache/pulsar/issues/21766#issuecomment-1903439335 https://github.com/apache/bookkeeper/releases/tag/release-4.16.0 ### Modifications `bookkeeper_server_ADD_ENTRY_REQUEST`->`bookkeeper_server_ADD_ENTRY` `bookkeeper_server_READ_ENTRY_REQUEST`->`bookkeeper_server_READ_ENTRY` ### Verifying this change - [ ] Make sure that the change passes the CI...
### Motivation When we call `pulsar-admin topics stats `, Pulsar will try to open a managed ledger even if the topic metadata does not exist. It costs a lot of...
### Motivation This PR https://github.com/apache/pulsar/pull/17573 has fixed cases that consumer commit offset periodically. It update `lastActive` field of cursor when consumer commit the offset. But there is still corner case...
[improve][broker]PIP-333 Add monitor metrics for the number of connections to client IPs and roles
For detailed improvement instructions, please refer to issues: https://github.com/apache/pulsar/issues/21934 ### Motivation Currently, Pulsar does not monitor the number of connections to client IPs and roles. When there are many business...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Pulsar 2.10.3 Admin Client 3.1.0 ### Minimal reproduce step ``` ./pulsar-3.1.0/bin/pulsar-admin --admin-url http://platform-pulsar-broker:8080...
Fixes https://github.com/apache/pulsar/issues/21968 ### Motivation The implementation of `org.apache.pulsar.broker.service.persistent.PersistentTopic#getLastMessageId` is not consistent with `org.apache.pulsar.broker.service.ServerCnx#handleGetLastMessageId`, for example, `ServerCnx#handleGetLastMessageId` may get last message id from the compacted topic, while `PersistentTopic#getLastMessageId` don't. ~~And flink-pulsar-connector...
Fixes #20576 ### Motivation There is a case resulted in duplicated consumer, if we add the same consumer twice continuously, then close consumer, the offline consumer would remain in consumerList,...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version os: CentOS Linux release 7.9.2009 (Core) pulsar: 2.10.5 ### Minimal reproduce step Occasionally...