This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 31c9f44cb53 [fix][misc] Make ConcurrentBitSet thread safe (#22361)
new 9ea7f6014b5 [improve][client] Add backoff for `seek` (#20963)
new 318ff3398d3 [fix][client] fix Reader.hasMessageAvailable might return
true after seeking to latest (#22201)
new e2070a87d55 [fix][broker] Fix wrong double-checked locking for
readOnActiveConsumerTask in dispatcher (#22279)
new d4610a0d601 [fix][broker] Avoid execute prepareInitPoliciesCacheAsync
if namespace is deleted (#22268)
new 1045f8be626 [fix][client] Fix wrong results of hasMessageAvailable and
readNext after seeking by timestamp (#22363)
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../SystemTopicBasedTopicPoliciesService.java | 66 +++---
.../PersistentDispatcherSingleActiveConsumer.java | 26 ++-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 19 ++
.../org/apache/pulsar/client/impl/ReaderTest.java | 112 +++++++++-
.../apache/pulsar/client/impl/ConsumerImpl.java | 227 +++++++++++++--------
.../pulsar/client/impl/ConsumerImplTest.java | 15 +-
6 files changed, 325 insertions(+), 140 deletions(-)
