This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 3afc29186a3 [improve][schema] Do not print error log with stacktrace
for 404 (#19130)
add 4b8f447d88d [feat][broker][PIP-195] Implement
BucketDelayedDeliveryTrackerFactory and load BucketDelayedDeliveryTracker -
part6 (#17756)
No new revisions were added by this update.
Summary of changes:
...va => BucketDelayedDeliveryTrackerFactory.java} | 36 ++++++++++++++++------
.../delayed/DelayedDeliveryTrackerFactory.java | 9 +++---
.../delayed/DelayedDeliveryTrackerLoader.java | 6 ++--
.../InMemoryDelayedDeliveryTrackerFactory.java | 4 ++-
.../pulsar/broker/service/BrokerService.java | 4 +--
...E2ETest.java => BucketDelayedDeliveryTest.java} | 19 +++++++-----
6 files changed, 50 insertions(+), 28 deletions(-)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/{InMemoryDelayedDeliveryTrackerFactory.java
=> BucketDelayedDeliveryTrackerFactory.java} (52%)
copy
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/{PersistentFailoverStreamingDispatcherE2ETest.java
=> BucketDelayedDeliveryTest.java} (68%)
