pulsar

pulsar copied to clipboard

[fix][client] Use byte schema for DLQ topic to avoid client side schema validation

2

Fixes #20635 ### Motivation When broker side schema validation is disabled and consumer receives an Avro message that has an incompatible schema then sending messages to DLQ fails due to...

tonisojandu

[Bug] [Broker] Entry digest does not match

19

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 2.9 ### Minimal reproduce step We use **transactinal feature** and start some tasks....

thetumbled

[fix][broker] Fix cannot cleanup expired ledger by trim ledgers

17

Fixes #15473 ### Motivation The pr [#10087](https://github.com/apache/pulsar/pull/10087) has fixed some case expired data cannot cleanup, but in some other case the bug reappeared . #### case 1 : the `slowestReaderPosition`...

Nicklee007

[fix][broker] The topic might reference a closed ledger

1

### Motivation We observe that a `normal topic` might reference a `closed ledger` and it never auto recover. will cause the producer and customer stuck. The root cause is related...

shibd

### Motivation Fix deadlock when disabling topic level Geo-Replication, which is using the metadata store thread to call another metadata reading(`clusters list`). You can reproduce the issue by `OneWayReplicatorUsingGlobalZKTest.testDeleteNonPartitionedTopic` logs...

poorbarcode

### Motivation Cherry-pick #22547 The get/grant/revoke permissions to a non-existed topic will be ok which may confuse the user. So it's better to check the topic existed before the grant...

Technoboy-

[Bug] Message loss on bookies and brokers restart

47

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

szkoludasebastian

[improve][test] Restart broker in SimpleProducerConsumerTest if ns deletion times out

1

Fixes #20553 ### Motivation SimpleProducerConsumerTest is flaky. deleteNamespaceWithRetry often times out. It seems that this became more flaky after #22627. ### Modifications * When the timeout happens, restart the broker....

lhotari

[improve][cli] Supports creating tokens with additional headers

3

### Motivation Currently, the tool that generates the token cannot attach headers. We should support it. For example, it makes sense to attach a [kid](https://www.rfc-editor.org/rfc/rfc7515#section-4.1.4) field for JWKS. ### Modifications...

coderzc

[fix][broker] Handle BucketDelayedDeliveryTracker recover failed

4

### Motivation We initialize `DelayedDeliveryTracker` when [dispatch messages](https://github.com/apache/pulsar/blob/master/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java#L1161-L1183) by calling `DelayedDeliveryTrackerFactory.newTracker` in [`AbstractBaseDispatcher`](https://github.com/apache/pulsar/blob/master/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java#L218). However, when we set `delayedDeliveryTrackerFactoryClassName` to `org.apache.pulsar.broker.delayed.BucketDelayedDeliveryTrackerFactory`, `BucketDelayedDeliveryTracker` has a chance to recover failed(see [here](https://github.com/apache/pulsar/blob/master/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java#L136-L139) ), it...

dao-jun