pulsar

pulsar copied to clipboard

### Motivation The ResourceLock revalidation, after a session expiry, is only getting triggered after the signal of session reconnected. If this is not coming through, there is no further attempt...

merlimat

[improve][broker]Ensure namespace deletion doesn't fail

3

### Motivation Deleting a namespace sometimes fails and leaves znodes around, especially the "bundle owner" nodes `/namespace/NAMESPACE/xxxxxx ` ### Modifications - ensure that all the children of /namespace/NAMESPACE are deleted,...

eolivelli

[improve][pip] PIP-347: add role field in consumer's stat

5

### Motivation pip-347 implementation pr：https://github.com/apache/pulsar/pull/22562 ### Modifications ### Verifying this change - [x] Make sure that the change passes the CI checks. *(Please pick either of the following options)* This...

thetumbled

[fix] Fix Reader can be stuck from transaction aborted messages.

9

### Motivation Fix Reader can be stuck from transaction aborted messages. Related to https://github.com/apache/pulsar/pull/22572 Since Reader's SubscriptionType is `Exclusive`, so we no need to handle DelayedDelivery messages. ### Modifications ###...

dao-jun

[improve][ml] Optimize read entries with skipCondition

7

### Motivation In https://github.com/apache/pulsar/pull/19035 we introduced `skipCondition` to filter-out delay delivery messages before read entries from Bookkeeper, and in https://github.com/apache/pulsar/pull/21739, we also filter-out deleted(individual acked messages) before read entries. However,...

dao-jun

Fixes #22638 ### Motivation Currently when Reader Builder is used to create Reader with `startMessageFromRollbackDuration` and if it fails due to connection issue and application retries to create a new...

rdhabalia

Pulsar Admin: expose the compression algoritm for "peek messages"

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation When troubleshooting production enviroments it would be helpful to see with "peek message"...

eolivelli

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

rdhabalia

[Bug] Code that is generated with the protobuf version 3.22.0+ doesn't work and logs a IllegalAccessError exception

6

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 3.0.0 ### Minimal reproduce step add the pulsar-client-3.0.0.jar as a dependency, try to...

artsiomau

[fix][ml]: subscription props could be lost in case of missing ledger during recovery

1

### Motivation During the recovery of the cursor, if the stored position points to a non existent ledger, the cursor is rewinded to the oldest position. In this case the...

nicoloboschi