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 5bb4b75 Add publishRateLimitedTimes to topic metrics (#13538)
add 74b5d50 [PIP-130] Apply redelivery backoff policy for ack timeout
(#13707)
No new revisions were added by this update.
Summary of changes:
.../pulsar/client/impl/NegativeAcksTest.java | 6 +-
.../impl/UnAcknowledgedMessagesTimeoutTest.java | 250 +++++++++++++++++----
.../pulsar/client/api/ConsumerConfiguration.java | 26 ++-
.../apache/pulsar/client/api/ConsumerBuilder.java | 19 +-
...deliveryBackoff.java => RedeliveryBackoff.java} | 6 +-
.../pulsar/client/impl/ConsumerBuilderImpl.java | 11 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 26 ++-
.../client/impl/MultiTopicsConsumerImpl.java | 18 +-
.../client/impl/MultiplierRedeliveryBackoff.java | 94 ++++++++
.../NegativeAckRedeliveryExponentialBackoff.java | 94 --------
.../pulsar/client/impl/NegativeAcksTracker.java | 4 +-
.../impl/UnAckedMessageRedeliveryTracker.java | 237 +++++++++++++++++++
.../pulsar/client/impl/UnAckedMessageTracker.java | 127 ++++++-----
.../impl/UnAckedTopicMessageRedeliveryTracker.java | 69 ++++++
.../client/impl/UnAckedTopicMessageTracker.java | 24 +-
.../pulsar/client/impl/UnackMessageIdWrapper.java | 94 ++++++++
.../impl/conf/ConsumerConfigurationData.java | 7 +-
.../api/MultiplierRedeliveryBackoffTest.java | 76 +++++++
.../api/NegativeAckRedeliveryBackoffTest.java | 55 -----
.../client/impl/ConsumerBuilderImplTest.java | 6 +-
.../client/impl/UnAckedMessageTrackerTest.java | 11 +-
21 files changed, 946 insertions(+), 314 deletions(-)
rename
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/{NegativeAckRedeliveryBackoff.java
=> RedeliveryBackoff.java} (85%)
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiplierRedeliveryBackoff.java
delete mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/NegativeAckRedeliveryExponentialBackoff.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageRedeliveryTracker.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedTopicMessageRedeliveryTracker.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnackMessageIdWrapper.java
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/api/MultiplierRedeliveryBackoffTest.java
delete mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/api/NegativeAckRedeliveryBackoffTest.java
