This is an automated email from the ASF dual-hosted git repository.
nodece pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from cd0ab9d6ad3 [improve][metadata] Add streaming scanChildren to
MetadataStore (#25701)
add 717a9c8f5af [fix][broker] Defer ack state updates until persistence
succeeds (#25528)
No new revisions were added by this update.
Summary of changes:
.../broker/service/AbstractBaseDispatcher.java | 2 +-
.../org/apache/pulsar/broker/service/Consumer.java | 345 ++++++++++++---------
.../apache/pulsar/broker/service/ServerCnx.java | 2 +-
.../apache/pulsar/broker/service/Subscription.java | 11 +-
.../nonpersistent/NonPersistentSubscription.java | 4 +-
.../service/persistent/PersistentSubscription.java | 79 +++--
.../persistent/PulsarCompactorSubscription.java | 11 +-
.../ReplicatedSubscriptionsController.java | 4 +-
.../pendingack/impl/PendingAckHandleImpl.java | 54 ++--
.../apache/pulsar/broker/admin/AdminApi2Test.java | 4 +-
.../broker/service/MessageCumulativeAckTest.java | 10 +-
.../pulsar/broker/service/PersistentTopicTest.java | 12 +-
.../service/TransactionMarkerDeleteTest.java | 4 +-
.../persistent/PersistentSubscriptionTest.java | 6 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 44 +--
15 files changed, 353 insertions(+), 239 deletions(-)
