pulsar

pulsar copied to clipboard

[fix][client] Add support for loading non-serializable properties with ConsumerBuilder::loadConf

2

### Motivation Currently `ConsumerBuilder::loadConf` resets non-serializable of `ConsumerConfigurationData` to `null`. It would be useful that `ConsumerBuilder::loadConf` supports loading non-serializable fields. An alternative is to not modify fields not present in...

cbornet

Automated security and update routine before every release

27

**Is your enhancement request related to a problem? Please describe.** To get the most out of every release regarding security, performance and "bug-freeness" it may be a good idea to...

hpvd

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version v2.10.2 ### Minimal reproduce step look into trivy powered inspection for vulnerabilities at...

hpvd

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version latest v2.10.2 ### Minimal reproduce step 1. look into trivy powered inspection for...

hpvd

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### What issue do you find in Pulsar docs? This should be done with https://github.com/apache/pulsar-client-python/pull/28....

tisonkun

### Motivation The exception occurs because `KeySharedPolicy` can't be deserialized. This change also adds unit tests for `loadConf` ### Modifications Add `JsonIgnore` on `ConsumerBuilder`'s `keySharedPolicy` field. ### Verifying this change...

cbornet

[fix][client] Fix ConfigurationDataUtils loadConf strategy

19

### Motivation When using `loadConf`, ConfigurationDataUtils was loading existing values in a Map using Jackson mapper. If there is a `@JsonIgnore`, Jackson ignores theses fields, but there will be forgotten...

mgrenonville

### Motivation A minor improvement by removing check `ack.getMessageIdsCount() == 1` for cumulative ack, making the code more clear and effective. Because we have checked it before at line418 ###...

AnonHxy

[fix][broker][branch-2.11] fix delete_when_subscriptions_caught_up doesn't work while have active consumers

1

### Motivation The current behavior for the `delete_when_subscriptions_caught_up` strategy is not expected. The active consumer will not be closed even if users enable `delete_when_subscriptions_caught_up` and there are no backlogs for...

codelipenghui

[fix][ml]fix wrong cursor state if repeat do close

2

### Motivation Do ` curosr.close` twice. expect cursor state: `Closed` actual cursor state: `Closing` ### Modifications Fixed the state change logic ### Documentation - [ ] `doc` - [ ]...

poorbarcode